Skip to content

Latest commit

 

History

History
58 lines (41 loc) · 3.75 KB

README.md

File metadata and controls

58 lines (41 loc) · 3.75 KB
Raw

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

Package kotlinx.coroutines.reactive

Utilities for Reactive Streams.