Top Classes
[default module]

Package io.reactivex.rxjava3.internal.operators.completable

Class Summary

Modifier and TypeClass and Description
public class
CompletableAmb

public class
CompletableAndThenCompletable

public class
CompletableCache

Consume the upstream source exactly once and cache its terminal event.

public class
CompletableConcat

public class
CompletableConcatArray

public class
CompletableConcatIterable

public class
CompletableCreate

public class
CompletableDefer

public class
CompletableDelay

public class
CompletableDetach

Breaks the references between the upstream and downstream when the Completable terminates.

public class
CompletableDisposeOn

public class
CompletableDoFinally

Execute an action after an onError, onComplete or a dispose event.

public class
CompletableDoOnEvent

public class
CompletableEmpty

public class
CompletableError

public class
CompletableErrorSupplier

public class
CompletableFromAction

public class
CompletableFromCallable

public class
CompletableFromObservable<T>

public class
CompletableFromPublisher<T>

public class
CompletableFromRunnable

public class
CompletableFromSingle<T>

public class
CompletableFromSupplier

Call a Supplier for each incoming CompletableObserver and signal completion or the thrown exception.

public class
CompletableFromUnsafeSource

public class
CompletableHide

Hides the identity of the upstream Completable and its Disposable sent through onSubscribe.

public class
CompletableLift

public class
CompletableMaterialize<
the element type of the source
T>

Turn the signal types of a Completable source into a single Notification of equal kind.

public class
CompletableMerge

public class
CompletableMergeArray

public class
CompletableMergeArrayDelayError

public class
CompletableMergeDelayErrorIterable

public class
CompletableMergeIterable

public class
CompletableNever

public class
CompletableObserveOn

public class
CompletableOnErrorComplete

public class
CompletableOnErrorReturn<
the value type
T>

Returns a value generated via a function if the main source signals an onError.

public class
CompletablePeek

public class
CompletableResumeNext

public class
CompletableSubscribeOn

public class
CompletableTakeUntilCompletable

Terminates the sequence if either the main or the other Completable terminate.

public class
CompletableTimeout

public class
CompletableTimer

Signals an onComplete event after the specified delay.

public class
CompletableToFlowable<T>

public class
CompletableToObservable<
the value type
T>

Wraps a Completable and exposes it as an Observable.

public class
CompletableToSingle<T>

public class
CompletableUsing<R>