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.awaitLast | Returns the last value from the given publisher |
| Publisher.awaitSingle | Returns the single value from the given publisher |
| Publisher.open | Subscribes to publisher and returns ReceiveChannel |
| Publisher.iterator | Subscribes to publisher and returns ChannelIterator |
Conversion functions:
| Name | Description |
|---|---|
| ReceiveChannel.toPublisher | Converts streaming channel to hot publisher |
Utilities for Reactive Streams.