diff --git a/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java b/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java index e7afc1e..9993a55 100644 --- a/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java +++ b/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java @@ -34,7 +34,6 @@ import it.tdlight.tdlibsession.FatalErrorType; import it.tdlight.tdlibsession.td.TdResult; import it.tdlight.tdlibsession.td.middle.AsyncTdMiddle; import it.tdlight.utils.MonoUtils; -import it.tdlight.utils.TdLightUtils; import java.io.File; import java.io.IOException; import java.nio.file.Files; @@ -56,7 +55,7 @@ public class AsyncTdEasy { private static final Logger logger = LoggerFactory.getLogger(AsyncTdEasy.class); - private final ReplayProcessor authState = ReplayProcessor.cacheLastOrDefault(new AuthorizationStateClosed()); + private final ReplayProcessor authState = ReplayProcessor.create(1); private final ReplayProcessor requestedDefinitiveExit = ReplayProcessor.cacheLastOrDefault(false); private final ReplayProcessor settings = ReplayProcessor.cacheLast(); private final EmitterProcessor globalErrors = EmitterProcessor.create();