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 |
Packages
Link copied to clipboard
Utilities for Reactive Streams.