Module kotlinx-coroutines-reactor

Utilities for Reactor.

Coroutine builders:

NameResultScopeDescription
monoMonoCoroutineScopeCold mono that starts coroutine on subscribe
fluxFluxCoroutineScopeCold flux that starts coroutine on subscribe

Note that Mono and Flux are a subclass of Reactive Streams Publisher and extensions for it are covered by kotlinx-coroutines-reactive module.

Conversion functions:

NameDescription
Job.asMonoConverts job to hot mono
Deferred.asMonoConverts deferred value to hot mono
ReceiveChannel.asFluxConverts streaming channel to hot flux
Scheduler.asCoroutineDispatcherConverts scheduler to CoroutineDispatcher

Package kotlinx.coroutines.reactor

Utilities for Reactor.