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 7691fc0..5ad713c 100644 --- a/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java +++ b/src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java @@ -152,7 +152,7 @@ public class AsyncTdEasy { * Get TDLib state */ public Flux getState() { - return Flux.from(authState).subscribeOn(scheduler); + return authState.distinct().subscribeOn(scheduler); } /**