Utilities for Reactor.
Wraps Reactor’s Context into CoroutineContext element for seamless integration Reactor and kotlinx.coroutines. Context.asCoroutineContext is defined to add Reactor’s Context elements as part of CoroutineContext. Coroutine context element that propagates information about Reactor’s Context through coroutines.
Extensions for External Classes
Creates cold reactive Flux that runs a given block in a coroutine.
Every time the returned flux is subscribed, it starts a new coroutine in the specified context.
Coroutine emits (Subscriber.onNext) values with
Creates cold mono that will run a given block in a coroutine and emits its result.
Every time the returned mono is subscribed, it starts a new coroutine.
If block result is