public abstract class CoroutinesUtils extends Object
Constructor and Description |
---|
CoroutinesUtils() |
Modifier and Type | Method and Description |
---|---|
static <T> reactor.core.publisher.Mono<T> |
deferredToMono(kotlinx.coroutines.Deferred<T> source)
Convert a
Deferred instance to a Mono . |
static Publisher<?> |
invokeSuspendingFunction(Method method,
Object target,
Object... args)
Invoke a suspending function and converts it to
Mono or
Flux . |
static <T> kotlinx.coroutines.Deferred<T> |
monoToDeferred(reactor.core.publisher.Mono<T> source)
Convert a
Mono instance to a Deferred . |
public static <T> reactor.core.publisher.Mono<T> deferredToMono(kotlinx.coroutines.Deferred<T> source)
Deferred
instance to a Mono
.public static <T> kotlinx.coroutines.Deferred<T> monoToDeferred(reactor.core.publisher.Mono<T> source)
Mono
instance to a Deferred
.