andreacavalli/tdlib-session-container
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix compilation issues

Browse Source
This commit is contained in:
Andrea Cavalli 2021-12-16 16:46:14 +01:00
parent 049a230fae
commit d2267963c8
3 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/it/tdlight/tdlibsession/td/easy/AsyncTdEasy.java
View File

@ -48,7 +48,6 @@ import java.util.concurrent.atomic.AtomicReference;
import org.reactivestreams.Publisher;
import org.warp.commonutils.log.Logger;
import org.warp.commonutils.log.LoggerFactory;
import org.warp.commonutils.error.InitializationException;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.core.publisher.Sinks;
@ -136,7 +135,7 @@ public class AsyncTdEasy {
try {
Files.createDirectories(Path.of(settings.databaseDirectory));
} catch (IOException ex) {
throw new InitializationException(ex);
throw new IllegalStateException(ex);
}
}

3
src/main/java/it/tdlight/tdlibsession/td/middle/direct/AsyncTdMiddleLocal.java
View File

@ -15,7 +15,6 @@ import it.tdlight.utils.MonoUtils;
import java.nio.file.Path;
import java.time.Duration;
import java.util.concurrent.atomic.AtomicReference;
import org.warp.commonutils.error.InitializationException;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.core.publisher.Sinks;
@ -65,7 +64,7 @@ public class AsyncTdMiddleLocal implements AsyncTdMiddle {
.getT1()
.start(botId, botAlias, true, implementationDetails, tuple.getT2())
.thenReturn(tuple.getT1()))
.onErrorMap(InitializationException::new)
.onErrorMap(IllegalStateException::new)
.doOnNext(this.cli::set)
.doOnError(this.startError::set)
.thenReturn(this);

1
src/main/java/it/tdlight/utils/MonoUtils.java
View File

@ -31,7 +31,6 @@ import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;
import org.reactivestreams.Publisher;
import org.reactivestreams.Subscription;
import org.warp.commonutils.concurrency.future.CompletableFutureUtils;
import org.warp.commonutils.functional.IOConsumer;
import org.warp.commonutils.log.Logger;
import org.warp.commonutils.log.LoggerFactory;