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
Completable.awaitCompleted	Awaits for completion of the completable value
Single.await	Awaits for completion of the single value and returns it
Observable.awaitFirst	Returns the first value from the given observable
Observable.awaitFirstOrDefault	Returns the first value from the given observable or default
Observable.awaitFirstOrElse	Returns the first value from the given observable or default from a function
Observable.awaitFirstOrNull	Returns the first value from the given observable or null
Observable.awaitLast	Returns the last value from the given observable
Observable.awaitSingle	Returns the single value from the given observable
Observable.openSubscription	Subscribes to observable and returns ReceiveChannel
Observable.iterator	Subscribes to observable and returns ChannelIterator

Conversion functions:

Name	Description
Job.asCompletable	Converts job to hot completable
Deferred.asSingle	Converts deferred value to hot single
ReceiveChannel.asObservable	Converts streaming channel to hot observable

Package kotlinx.coroutines.experimental.rx1

Utilities for RxJava 1.x.