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.