Module kotlinx-coroutines-reactive
Utilities for Reactive Streams.
Coroutine builders:
| Name | Result | Scope | Description |
|---|---|---|---|
| publish | Publisher |
ProducerScope | Cold reactive publisher that starts coroutine on subscribe |
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 |
| Publisher.openSubscription | Subscribes to publisher and returns ReceiveChannel |
Conversion functions:
| Name | Description |
|---|---|
| ReceiveChannel.asPublisher | Converts streaming channel to hot publisher |
Package kotlinx.coroutines.reactive
Utilities for Reactive Streams.