From b13f634b09bec4ce43148a53335b2d733ae4a3cf Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Sat, 22 May 2021 14:47:12 +0200
Subject: [PATCH] Update reactor

---
 .../td/middle/server/AsyncTdMiddleEventBusServer.java           | 2 +-
 1 file changed, 1 insertion(+), 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 1b3655c..beb62e9 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
@@ -198,7 +198,7 @@ public class AsyncTdMiddleEventBusServer extends AbstractVerticle {
 						readyToReceiveConsumer.endHandler(h -> sink.complete());
 					})
 					.take(1)
-					.limitRequest(1)
+					.take(1, true)
 					.single()
 					.doOnNext(s -> logger.trace("Received ready-to-receive request from client"))
 					.flatMap(msg -> this.pipeFlux