diff --git a/src/main/java/it/cavallium/TransferServiceImpl.java b/src/main/java/it/cavallium/TransferServiceImpl.java index 710f092..4b49445 100644 --- a/src/main/java/it/cavallium/TransferServiceImpl.java +++ b/src/main/java/it/cavallium/TransferServiceImpl.java @@ -32,7 +32,6 @@ import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.reactivestreams.Publisher; import org.slf4j.LoggerFactory; -import org.warp.commonutils.error.InitializationException; import reactor.core.publisher.EmitterProcessor; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; @@ -129,7 +128,7 @@ public class TransferServiceImpl implements TransferService { }) .build()) .then(Mono.defer(() -> { - var clientStateFlux = client.getState().skip(1).publish().autoConnect(2); + var clientStateFlux = client.getState().publish().autoConnect(2); clientStateFlux .filter(state -> state.getConstructor() == AuthorizationStateClosing.CONSTRUCTOR diff --git a/tdlib-session-container b/tdlib-session-container new file mode 160000 index 0000000..bc40e2b --- /dev/null +++ b/tdlib-session-container @@ -0,0 +1 @@ +Subproject commit bc40e2b9e60857e3b84850d11ba399a2afc51073