Utilities for Reactive Streams.
Coroutine builders:
| Name | Result | Scope | Description |
|---|---|---|---|
| publish | Publisher | ProducerScope | Cold reactive publisher that starts coroutine on subscribe |
Integration with Flow:
| Name | Result | Description |
|---|---|---|
| Publisher.asFlow | Flow | Converts the given publisher to flow |
| Flow.asPublisher | Publisher | Converts the given flow to the TCK-compliant publisher |
If these adapters are used along with kotlinx-coroutines-reactor in the classpath, then Reactor's Context is properly propagated as coroutine context element (ReactorContext) and vice versa.
Suspending extension functions and suspending iteration:
| Name | Description |
|---|---|
| Publisher.awaitFirst | Returns the first value from the given publisher |
| Publisher.awaitFirstOrDefault | Returns the first value from the given publisher or default |
| Publisher.awaitFirstOrElse | Returns the first value from the given publisher or default from a function |
| Publisher.awaitFirstOrNull | Returns the first value from the given publisher or null |
| Publisher.awaitLast | Returns the last value from the given publisher |
| Publisher.awaitSingle | Returns the single value from the given publisher |
Utilities for Reactive Streams.