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 |
Utilities for Reactive Streams.