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

Add toOptional

This commit is contained in:
Andrea Cavalli 2021-06-01 17:08:59 +02:00
parent b13f634b09
commit 85594c61ea
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -20,6 +20,7 @@ import it.tdlight.tdlibsession.td.TdError;
import it.tdlight.tdlibsession.td.TdResult;
import java.time.Duration;
import java.util.Objects;
import java.util.Optional;
import java.util.Queue;
import java.util.concurrent.Callable;
import java.util.concurrent.CompletableFuture;
@ -430,6 +431,10 @@ public class MonoUtils {
);
}
public static <R> Mono<Optional<R>> toOptional(Mono<R> mono) {
return mono.map(Optional::of).defaultIfEmpty(Optional.empty());
}
public static class SinkRWStream<T> implements io.vertx.core.streams.WriteStream<T>, io.vertx.core.streams.ReadStream<T> {
private final Many<T> sink;