SchedulerCoroutineDispatcher

Implements CoroutineDispatcher on top of an arbitrary Scheduler.

kotlinx.coroutines.experimental.Deferred

kotlinx.coroutines.experimental.Job

kotlinx.coroutines.experimental.channels.ReceiveChannel

reactor.core.scheduler.Scheduler

flux

Creates cold reactive Flux that runs a given block in a coroutine. Every time the returned flux is subscribed, it starts a new coroutine in the specified context. Coroutine emits items with send. Unsubscribing cancels running coroutine.

mono

Creates cold mono that will run a given block in a coroutine. Every time the returned mono is subscribed, it starts a new coroutine. Coroutine returns a single, possibly null value. Unsubscribing cancels running coroutine.