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 implements io.vertx.core.streams.WriteStream, io.vertx.core.streams.ReadStream { private final Many sink;