Permalink
Fetching contributors…
Cannot retrieve contributors at this time
43 lines (33 sloc) 2.87 KB

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.

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.