From 85594c61ead9a8eaa045fa8ec8f3b526f62de3f4 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Tue, 1 Jun 2021 17:08:59 +0200
Subject: [PATCH] Add toOptional

---
 src/main/java/it/tdlight/utils/MonoUtils.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/src/main/java/it/tdlight/utils/MonoUtils.java b/src/main/java/it/tdlight/utils/MonoUtils.java
index 1311e16..cfc6b4d 100644
--- a/src/main/java/it/tdlight/utils/MonoUtils.java
+++ b/src/main/java/it/tdlight/utils/MonoUtils.java
@@ -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;