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.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 |
Publisher.iterator | Subscribes to publisher and returns ChannelIterator |
Conversion functions:
Name | Description |
---|---|
ReceiveChannel.asPublisher | Converts streaming channel to hot publisher |
Utilities for Reactive Streams.