Skip to content

Latest commit

 

History

History
47 lines (37 loc) · 3.74 KB

File metadata and controls

47 lines (37 loc) · 3.74 KB

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.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

Package kotlinx.coroutines.experimental.reactive

Utilities for Reactive Streams.