From 45af656d9028d9103891ef82fe96cfe0439ad0ad Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Thu, 5 Aug 2021 21:28:57 +0200
Subject: [PATCH] Add utility method

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

diff --git a/src/main/java/it/tdlight/utils/MonoUtils.java b/src/main/java/it/tdlight/utils/MonoUtils.java
index da6a6ab..e9ef967 100644
--- a/src/main/java/it/tdlight/utils/MonoUtils.java
+++ b/src/main/java/it/tdlight/utils/MonoUtils.java
@@ -33,6 +33,7 @@ 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;
 import reactor.core.CoreSubscriber;
@@ -287,4 +288,15 @@ public class MonoUtils {
 				.defaultIfEmpty(false);
 	}
 
+	@FunctionalInterface
+	public interface VoidCallable {
+		void call() throws Exception;
+	}
+
+	public static Mono<?> fromVoidCallable(VoidCallable callable) {
+		return Mono.fromCallable(() -> {
+			callable.call();
+			return null;
+		});
+	}
 }