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 |
| TimedScheduler.asCoroutineDispatcher | Converts scheduler to CoroutineDispatcher supporting [Delay] |
Utilities for Reactor.