Skip to content

Latest commit

 

History

History

kotlinx-coroutines-rx1

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
 
 
 
 
 
 

Module kotlinx-coroutines-rx1

Utilities for RxJava 1.x.

Coroutine builders:

Name Result Scope Description
rxCompletable Completable CoroutineScope Cold completable that starts coroutine on subscribe
rxSingle Single CoroutineScope Cold single that starts coroutine on subscribe
rxObservable Observable ProducerScope Cold observable that starts coroutine on subscribe

Suspending extension functions and suspending iteration:

Name Description
Single.await Awaits for completion of the single value and returns it
Observable.awaitFirst Returns the first value from the given observable
Observable.awaitLast Returns the last value from the given observable
Observable.awaitSingle Returns the single value from the given observable
Observable.open Subscribes to observable and returns ReceiveChannel
Observable.iterator Subscribes to observable and returns ChannelIterator

Conversion functions:

Name Description
Job.toCompletable Converts job to hot completable
Deferred.toSingle Converts deferred value to hot single
ReceiveChannel.toObservable Converts streaming channel to hot observable

Package kotlinx.coroutines.experimental.rx1

Utilities for RxJava 1.x.