Module kotlinx-coroutines-reactor

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

Package kotlinx.coroutines.reactor

Utilities for Reactor.