Update MonoUtils
This commit is contained in:
parent
0bc2a61674
commit
3e542d9ec4
@ -421,6 +421,19 @@ public class MonoUtils {
|
|||||||
}).subscribeOn(Schedulers.boundedElastic());
|
}).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> {
|
public static class SinkRWStream<T> implements io.vertx.core.streams.WriteStream<T>, io.vertx.core.streams.ReadStream<T> {
|
||||||
|
|
||||||
private final Many<T> sink;
|
private final Many<T> sink;
|
||||||
|
Loading…
Reference in New Issue
Block a user