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.