From ab70ca31efeee8c6abdc60649ddd831abcf8421c Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Sun, 24 Jan 2021 23:24:13 +0100
Subject: [PATCH] Update AsyncTdDirectImpl.java

---
 .../it/tdlight/tdlibsession/td/direct/AsyncTdDirectImpl.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/it/tdlight/tdlibsession/td/direct/AsyncTdDirectImpl.java b/src/main/java/it/tdlight/tdlibsession/td/direct/AsyncTdDirectImpl.java
index d17fa9c..b9187b3 100644
--- a/src/main/java/it/tdlight/tdlibsession/td/direct/AsyncTdDirectImpl.java
+++ b/src/main/java/it/tdlight/tdlibsession/td/direct/AsyncTdDirectImpl.java
@@ -74,7 +74,7 @@ public class AsyncTdDirectImpl implements AsyncTdDirect {
 		return telegramClientFactory.create(implementationDetails)
 				.flatMapMany(client -> Flux
 						.<TdApi.Object>create(updatesSink -> {
-							client.initialize((TdApi.Object object) -> {
+							Schedulers.boundedElastic().schedule(() -> client.initialize((TdApi.Object object) -> {
 								updatesSink.next(object);
 								// Close the emitter if receive closed state
 								if (object.getConstructor() == UpdateAuthorizationState.CONSTRUCTOR
@@ -84,7 +84,7 @@ public class AsyncTdDirectImpl implements AsyncTdDirect {
 									closedFromTd.tryEmitValue(true);
 									updatesSink.complete();
 								}
-							}, updatesSink::error, updatesSink::error);
+							}, updatesSink::error, updatesSink::error));
 
 							if (td.tryEmitValue(client).isFailure()) {
 								updatesSink.error(new TdError(500, "Failed to emit td client"));