From e3ce18023f5d0a190779b38abc3ea58cd0bfb6f6 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Wed, 30 Jun 2021 10:59:33 +0200
Subject: [PATCH] Remove unused code

---
 .../td/middle/server/AsyncTdMiddleEventBusServer.java            | 1 -
 1 file changed, 1 deletion(-)

diff --git a/src/main/java/it/tdlight/tdlibsession/td/middle/server/AsyncTdMiddleEventBusServer.java b/src/main/java/it/tdlight/tdlibsession/td/middle/server/AsyncTdMiddleEventBusServer.java
index beb62e9..4693e13 100644
--- a/src/main/java/it/tdlight/tdlibsession/td/middle/server/AsyncTdMiddleEventBusServer.java
+++ b/src/main/java/it/tdlight/tdlibsession/td/middle/server/AsyncTdMiddleEventBusServer.java
@@ -197,7 +197,6 @@ public class AsyncTdMiddleEventBusServer extends AbstractVerticle {
 						readyToReceiveConsumer.handler(sink::next);
 						readyToReceiveConsumer.endHandler(h -> sink.complete());
 					})
-					.take(1)
 					.take(1, true)
 					.single()
 					.doOnNext(s -> logger.trace("Received ready-to-receive request from client"))