kotlinx-coroutines-reactor
Utilities for Reactor.
Coroutine builders:
Name | Result | Scope | Description |
---|---|---|---|
mono | Mono | CoroutineScope | A cold Mono that starts the coroutine on subscription |
flux | Flux | CoroutineScope | A cold Flux that starts the coroutine on subscription |
Note that Mono
and Flux
are subclasses of Reactive Streams' Publisher
and extensions for it are covered by the ../kotlinx-coroutines-reactive module.
Integration with Flow:
Name | Result | Description |
---|---|---|
Flow.asFlux | Flux | Converts the given flow to a TCK-compliant Flux. |
This adapter is integrated with Reactor's Context
and coroutines' ReactorContext.
Conversion functions:
Name | Description |
---|---|
Job.asMono | Converts a job to a hot Mono |
Deferred.asMono | Converts a deferred value to a hot Mono |
Scheduler.asCoroutineDispatcher | Converts a scheduler to a CoroutineDispatcher |
Packages
Link copied to clipboard
Utilities for Reactor.