andreacavalli/tdlib-session-container
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Update reactor

Browse Source
This commit is contained in:
Andrea Cavalli 2021-05-22 14:47:12 +02:00
parent 9446ebd1bc
commit b13f634b09
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/it/tdlight/tdlibsession/td/middle/server/AsyncTdMiddleEventBusServer.java
View File

@ -198,7 +198,7 @@ public class AsyncTdMiddleEventBusServer extends AbstractVerticle {
readyToReceiveConsumer.endHandler(h -> sink.complete()); readyToReceiveConsumer.endHandler(h -> sink.complete());
}) })
.take(1) .take(1)
.limitRequest(1) .take(1, true)
.single() .single()
.doOnNext(s -> logger.trace("Received ready-to-receive request from client")) .doOnNext(s -> logger.trace("Received ready-to-receive request from client"))
.flatMap(msg -> this.pipeFlux .flatMap(msg -> this.pipeFlux