Package kotlinx.coroutines.experimental.rx1
Utilities for RxJava 1.x.
Types
class SchedulerCoroutineDispatcher : Implements CoroutineDispatcher on top of an arbitrary Scheduler. |
Extensions for External Classes
Functions
fun 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. |
|
fun <T> rxObservable( Creates cold Observable that runs a given block in a coroutine.
Every time the returned observable is subscribed, it starts a new coroutine.
Coroutine emits items with |
|
fun <T> rxSingle( Creates cold Single that runs a given block in a coroutine. Every time the returned single is subscribed, it starts a new coroutine. Coroutine returns a single value. Unsubscribing cancels running coroutine. |