From e9dd378765ea6440154b7c9713b7de11d5818f29 Mon Sep 17 00:00:00 2001 From: Andrea Cavalli Date: Thu, 14 Jan 2021 21:09:44 +0100 Subject: [PATCH] Update AsyncTdMiddleEventBusServer.java --- .../td/middle/server/AsyncTdMiddleEventBusServer.java | 1 + 1 file changed, 1 insertion(+) 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 a57119a..37fbbc4 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 @@ -240,6 +240,7 @@ public class AsyncTdMiddleEventBusServer { .replace(" = ", "=")); } }).bufferTimeout(tdOptions.getEventsSize(), local ? Duration.ofMillis(1) : Duration.ofMillis(100)) + .filter(l -> !l.isEmpty()) .windowTimeout(1, Duration.ofSeconds(5)) .flatMap(w -> w.defaultIfEmpty(Collections.emptyList())) .map(TdResultList::new).doFinally(s -> {