A RetroSearch Logo

Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Search Query:

Showing content from https://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-rx3/index.html below:

Website Navigation


coroutines-rx3 | kotlinx.coroutines – Kotlin Programming Language

Utilities for RxJava 3.x.

Coroutine builders:

Name Result Scope Description rxCompletable Completable CoroutineScope Cold completable that starts coroutine on subscribe rxMaybe Maybe CoroutineScope Cold maybe 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 rxFlowable Flowable ProducerScope Cold observable that starts coroutine on subscribe with backpressure support

Integration with Flow:

Name Result Description Flow.asFlowable Flowable Converts the given flow to a cold Flowable. Flow.asObservable Observable Converts the given flow to a cold Observable. ObservableSource.asFlow Flow Converts the given cold ObservableSource to flow

Suspending extension functions and suspending iteration:

Name Description CompletableSource.await Awaits for completion of the completable value MaybeSource.awaitSingle Awaits for the value of the maybe and returns it or throws an exception MaybeSource.awaitSingleOrNull Awaits for the value of the maybe and returns it or null SingleSource.await Awaits for completion of the single value and returns it ObservableSource.awaitFirst Awaits for the first value from the given observable ObservableSource.awaitFirstOrDefault Awaits for the first value from the given observable or default ObservableSource.awaitFirstOrElse Awaits for the first value from the given observable or default from a function ObservableSource.awaitFirstOrNull Awaits for the first value from the given observable or null ObservableSource.awaitLast Awaits for the last value from the given observable ObservableSource.awaitSingle Awaits for the single value from the given observable

Note that Flowable is a subclass of Reactive Streams Publisher and extensions for it are covered by ../kotlinx-coroutines-reactive module.

Conversion functions:

Name Description Job.asCompletable Converts job to hot completable Deferred.asSingle Converts deferred value to hot single Scheduler.asCoroutineDispatcher Converts scheduler to CoroutineDispatcher

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4