Utilities for Reactor.

All Types

reactor.util.context.Context (extensions in package kotlinx.coroutines.reactor)

kotlinx.coroutines.CoroutineScope (extensions in package kotlinx.coroutines.reactor)

kotlinx.coroutines.Deferred (extensions in package kotlinx.coroutines.reactor)

kotlinx.coroutines.flow.Flow (extensions in package kotlinx.coroutines.reactor)

kotlinx.coroutines.Job (extensions in package kotlinx.coroutines.reactor)

kotlinx.coroutines.reactor.ReactorContext

Wraps Reactor’s Context into CoroutineContext element for seamless integration Reactor and kotlinx.coroutines. Context.asCoroutineContext is defined to add Reactor’s Context elements as part of CoroutineContext. Coroutine context element that propagates information about Reactor’s Context through coroutines.

kotlinx.coroutines.channels.ReceiveChannel (extensions in package kotlinx.coroutines.reactor)

reactor.core.scheduler.Scheduler (extensions in package kotlinx.coroutines.reactor)

kotlinx.coroutines.reactor.SchedulerCoroutineDispatcher

Implements CoroutineDispatcher on top of an arbitrary Scheduler.