Utilities for Reactive Streams.

Coroutine builders:

Name Result Scope Description
publish Publisher ProducerScope Cold reactive publisher that starts coroutine on subscribe

Integration with Flow:

Name Result Description
Publisher.asFlow Flow Converts the given publisher to flow
Flow.asPublisher Publisher Converts the given flow to the 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

Packages

kotlinx.coroutines.reactive

Utilities for Reactive Streams.

Index

All Types