SchedulerCoroutineDispatcher

Implements CoroutineDispatcher on top of an arbitrary Scheduler.

io.reactivex.CompletableSource

io.reactivex.MaybeSource

io.reactivex.ObservableSource

io.reactivex.Scheduler

io.reactivex.SingleSource

kotlinx.coroutines.experimental.Deferred

kotlinx.coroutines.experimental.Job

kotlinx.coroutines.experimental.channels.ReceiveChannel

rxCompletable

Creates cold Completable that runs a given block in a coroutine. Every time the returned completable is subscribed, it starts a new coroutine. Unsubscribing cancels running coroutine.

rxFlowable

Creates cold flowable that will run a given block in a coroutine. Every time the returned flowable is subscribed, it starts a new coroutine. Coroutine emits items with send. Unsubscribing cancels running coroutine.

rxMaybe

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

rxObservable

Creates cold observable that will run a given block in a coroutine. Every time the returned observable is subscribed, it starts a new coroutine. Coroutine emits items with send. Unsubscribing cancels running coroutine.

rxSingle

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