kotlinx-coroutines-reactor

Utilities for Reactor.

Coroutine builders:

NameResultScopeDescription
monoMonoCoroutineScopeA cold Mono that starts the coroutine on subscription
fluxFluxCoroutineScopeA cold Flux that starts the coroutine on subscription

Note that Mono and Flux are subclasses of Reactive Streams' Publisher and extensions for it are covered by the ../kotlinx-coroutines-reactive module.

Integration with Flow:

NameResultDescription
Flow.asFluxFluxConverts the given flow to a TCK-compliant Flux.

This adapter is integrated with Reactor's Context and coroutines' ReactorContext.

Conversion functions:

NameDescription
Job.asMonoConverts a job to a hot Mono
Deferred.asMonoConverts a deferred value to a hot Mono
Scheduler.asCoroutineDispatcherConverts a scheduler to a CoroutineDispatcher

Packages

Link copied to clipboard

Utilities for Reactor.