Utilities for Reactor.

Coroutine builders:

Name Result Scope Description
mono Mono CoroutineScope Cold mono that starts coroutine on subscribe
flux Flux CoroutineScope Cold 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.

Integration with Flow:

Name Result Description
Flow.asFlux Flux Converts the given flow to the TCK-compliant Flux.

This adapter is integrated with Reactor’s Context and coroutines ReactorContext.

Conversion functions:

Name Description
Job.asMono Converts job to hot mono
Deferred.asMono Converts deferred value to hot mono
ReceiveChannel.asFlux Converts streaming channel to hot flux
Scheduler.asCoroutineDispatcher Converts scheduler to CoroutineDispatcher



Utilities for Reactor.


All Types