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.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 |
Utilities for RxJava 1.x.