From 3e542d9ec42542c024265fc904275884b1328009 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Tue, 2 Mar 2021 12:01:13 +0100
Subject: [PATCH] Update MonoUtils

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

diff --git a/src/main/java/it/tdlight/utils/MonoUtils.java b/src/main/java/it/tdlight/utils/MonoUtils.java
index 2c4be08..d149d17 100644
--- a/src/main/java/it/tdlight/utils/MonoUtils.java
+++ b/src/main/java/it/tdlight/utils/MonoUtils.java
@@ -421,6 +421,19 @@ public class MonoUtils {
 		}).subscribeOn(Schedulers.boundedElastic());
 	}
 
+	public static Scheduler newBoundedSingle(String name) {
+		return newBoundedSingle(name, false);
+	}
+
+	public static Scheduler newBoundedSingle(String name, boolean daemon) {
+		return Schedulers.newBoundedElastic(1,
+				Schedulers.DEFAULT_BOUNDED_ELASTIC_QUEUESIZE,
+				name,
+				Integer.MAX_VALUE,
+				daemon
+		);
+	}
+
 	public static class SinkRWStream<T> implements io.vertx.core.streams.WriteStream<T>, io.vertx.core.streams.ReadStream<T> {
 
 		private final Many<T> sink;