andreacavalli/TransferBot
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Update TransferServiceImpl.java and tdlib-session-container

Browse Source
This commit is contained in:
Andrea Cavalli 2020-10-19 14:19:57 +02:00
parent 39751747c3
commit b9fbc22c11
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/it/cavallium/TransferServiceImpl.java
View File

@ -32,7 +32,6 @@ import java.util.stream.Collectors;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.reactivestreams.Publisher; import org.reactivestreams.Publisher;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.warp.commonutils.error.InitializationException;
import reactor.core.publisher.EmitterProcessor; import reactor.core.publisher.EmitterProcessor;
import reactor.core.publisher.Flux; import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
@ -129,7 +128,7 @@ public class TransferServiceImpl implements TransferService {
}) })
.build()) .build())
.then(Mono.defer(() -> { .then(Mono.defer(() -> {
var clientStateFlux = client.getState().skip(1).publish().autoConnect(2); var clientStateFlux = client.getState().publish().autoConnect(2);
clientStateFlux clientStateFlux
.filter(state -> state.getConstructor() == AuthorizationStateClosing.CONSTRUCTOR .filter(state -> state.getConstructor() == AuthorizationStateClosing.CONSTRUCTOR

1
tdlib-session-container Submodule

@ -0,0 +1 @@
Subproject commit bc40e2b9e60857e3b84850d11ba399a2afc51073