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

Fix logging

Browse Source
This commit is contained in:
Andrea Cavalli 2021-01-13 17:44:24 +01:00
parent 841045322f
commit 449d513f1a
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -267,12 +267,10 @@ public class AsyncTdMiddleEventBusServer extends AbstractVerticle {
}).bufferTimeout(1000, local ? Duration.ofMillis(1) : Duration.ofMillis(100))
.windowTimeout(1, Duration.ofSeconds(5))
.flatMap(w -> w.defaultIfEmpty(Collections.emptyList()))
.map(TdResultList::new).doOnTerminate(() -> {
System.out.println("<=: end (1)");
}).doOnComplete(() -> {
System.out.println("<=: end (2)");
}).doFinally(s -> {
System.out.println("<=: end (3)");
.map(TdResultList::new).doFinally(s -> {
if (OUTPUT_REQUESTS) {
System.out.println("<=: end (3)");
}
this.undeploy(() -> {});
});
var fluxCodec = new TdResultListMessageCodec();