Package-level declarations

Implements CoroutineDispatcher on top of an arbitrary Scheduler.

Converts this job to the hot reactive completable that signals with onCompleted when the corresponding job completes.

Converts an instance of Scheduler to an implementation of CoroutineDispatcher and provides native support of delay and withTimeout.

Transforms given cold ObservableSource into cold Flow.

Converts the given flow to a cold flowable. The original flow is cancelled when the flowable subscriber is disposed.

Converts this deferred value to the hot reactive maybe that signals onComplete, onSuccess or onError.

Converts the given flow to a cold observable. The original flow is cancelled when the observable subscriber is disposed.

Converts an instance of CoroutineDispatcher to an implementation of Scheduler.

Converts this deferred value to the hot reactive single that signals either onSuccess or onError.

Awaits for completion of this completable without blocking the thread. Returns Unit, or throws the corresponding exception if this completable produces an error.

Awaits for completion of the single value response without blocking the thread. Returns the resulting value, or throws the corresponding exception if this response produces an error.

Awaits the first value from the given Observable without blocking the thread and returns the resulting value, or, if the observable has produced an error, throws the corresponding exception.

Awaits the first value from the given Observable, or returns the default value if none is emitted, without blocking the thread, and returns the resulting value, or, if this observable has produced an error, throws the corresponding exception.

Awaits the first value from the given Observable, or calls defaultValue to get a value if none is emitted, without blocking the thread, and returns the resulting value, or, if this observable has produced an error, throws the corresponding exception.

Awaits the first value from the given Observable, or returns null if none is emitted, without blocking the thread, and returns the resulting value, or, if this observable has produced an error, throws the corresponding exception.

Awaits the last value from the given Observable without blocking the thread and returns the resulting value, or, if this observable has produced an error, throws the corresponding exception.

Awaits for completion of the MaybeSource without blocking the thread. Returns the resulting value, or throws if either no value is produced or this MaybeSource produces an error.

Awaits the single value from the given observable without blocking the thread and returns the resulting value, or, if this observable has produced an error, throws the corresponding exception.

Awaits for completion of the MaybeSource without blocking the thread. Returns the resulting value, or null if no value is produced, or throws the corresponding exception if this MaybeSource produces an error.

Subscribes to this MaybeSource and performs the specified action for each received element.

Subscribes to this ObservableSource and performs the specified action for each received element.

Creates cold Completable that runs a given block in a coroutine and emits its result. Every time the returned completable is subscribed, it starts a new coroutine. Unsubscribing cancels running coroutine. Coroutine context can be specified with context argument. If the context does not have any dispatcher nor any other ContinuationInterceptor, then Dispatchers.Default is used. Method throws IllegalArgumentException if provided context contains a Job instance.

Creates cold flowable that will run a given block in a coroutine. Every time the returned flowable is subscribed, it starts a new coroutine.

Creates cold maybe that will run a given block in a coroutine and emits its result. If block result is null, onComplete is invoked without a value. Every time the returned observable is subscribed, it starts a new coroutine. Unsubscribing cancels running coroutine. Coroutine context can be specified with context argument. If the context does not have any dispatcher nor any other ContinuationInterceptor, then Dispatchers.Default is used. Method throws IllegalArgumentException if provided context contains a Job instance.

Creates cold observable that will run a given block in a coroutine. Every time the returned observable is subscribed, it starts a new coroutine.

Creates cold single that will run a given block in a coroutine and emits its result. Every time the returned observable is subscribed, it starts a new coroutine. Unsubscribing cancels running coroutine. Coroutine context can be specified with context argument. If the context does not have any dispatcher nor any other ContinuationInterceptor, then Dispatchers.Default is used. Method throws IllegalArgumentException if provided context contains a Job instance.