Module kotlinx-coroutines-reactive

Utilities for Reactive Streams.

Coroutine builders:

Name	Result	Scope	Description
kotlinx.coroutines.reactive.publish	Publisher	ProducerScope	Cold reactive publisher that starts the coroutine on subscribe

Integration with Flow:

Name	Result	Description
Publisher.asFlow	Flow	Converts the given publisher to a flow
Flow.asPublisher	Publisher	Converts the given flow to a TCK-compliant publisher

If these adapters are used along with kotlinx-coroutines-reactor in the classpath, then Reactor's Context is properly propagated as coroutine context element (ReactorContext) and vice versa.

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

<!--- MODULE kotlinx-coroutines-core --> <!--- INDEX kotlinx.coroutines --> <!--- INDEX kotlinx.coroutines.flow --> <!--- INDEX kotlinx.coroutines.channels --> <!--- MODULE kotlinx-coroutines-reactive --> <!--- INDEX kotlinx.coroutines.reactive --> <!--- END -->

Package kotlinx.coroutines.reactive

Utilities for Reactive Streams.