Uses of Interface
io.reactivex.rxjava3.core.CompletableObserver

Packages that use CompletableObserver

Package	Description
io.reactivex.rxjava3.core	Base reactive classes: Flowable, Observable, Single, Maybe and Completable; base reactive consumers; other common base interfaces.
io.reactivex.rxjava3.internal.disposables
io.reactivex.rxjava3.internal.jdk8
io.reactivex.rxjava3.internal.observers
io.reactivex.rxjava3.internal.operators.completable
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.maybe
io.reactivex.rxjava3.internal.operators.mixed
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.operators.single
io.reactivex.rxjava3.internal.util
io.reactivex.rxjava3.observers	Default wrappers and implementations for observer-based consumer classes and interfaces, including disposable and resource-tracking variants and the TestObserver that allows unit testing Observable-, Single-, Maybe- and Completable-based flows.
io.reactivex.rxjava3.plugins	Contains the central plugin handler RxJavaPlugins class to hook into the lifecycle of the base reactive types and schedulers.
io.reactivex.rxjava3.subjects	Classes representing so-called hot sources, aka subjects, that implement a base reactive class and the respective consumer type at once to allow forms of multicasting events to multiple consumers as well as consuming another base reactive type of their kind.

Uses of CompletableObserver in io.reactivex.rxjava3.core

Methods in io.reactivex.rxjava3.core with type parameters of type CompletableObserver

Modifier and Type	Method	Description
final <@NonNull E extends CompletableObserver> E	Completable.subscribeWith(@NonNull E observer)	Subscribes a given CompletableObserver (subclass) to this Completable and returns the given CompletableObserver as is.

Methods in io.reactivex.rxjava3.core that return CompletableObserver

Modifier and Type	Method	Description
@NonNull CompletableObserver	CompletableOperator.apply(@NonNull CompletableObserver observer)	Applies a function to the child CompletableObserver and returns a new parent CompletableObserver.

Methods in io.reactivex.rxjava3.core with parameters of type CompletableObserver

Modifier and Type	Method	Description
@NonNull CompletableObserver	CompletableOperator.apply(@NonNull CompletableObserver observer)	Applies a function to the child CompletableObserver and returns a new parent CompletableObserver.
final void	Completable.blockingSubscribe(@NonNull CompletableObserver observer)	Subscribes to the current Completable and calls the appropriate CompletableObserver method on the current thread.
final void	Completable.safeSubscribe(@NonNull CompletableObserver observer)	Wraps the given CompletableObserver, catches any RuntimeExceptions thrown by its CompletableObserver.onSubscribe(Disposable), CompletableObserver.onError(Throwable) or CompletableObserver.onComplete() methods and routes those to the global error handler via RxJavaPlugins.onError(Throwable).
final void	Completable.subscribe(@NonNull CompletableObserver observer)
void	CompletableSource.subscribe(@NonNull CompletableObserver observer)	Subscribes the given CompletableObserver to this CompletableSource instance.
protected abstract void	Completable.subscribeActual(@NonNull CompletableObserver observer)	Implement this method to handle the incoming CompletableObservers and perform the business logic in your operator.

Uses of CompletableObserver in io.reactivex.rxjava3.internal.disposables

Methods in io.reactivex.rxjava3.internal.disposables with parameters of type CompletableObserver

Modifier and Type	Method	Description
static void	EmptyDisposable.complete(CompletableObserver observer)
static void	EmptyDisposable.error(Throwable e, CompletableObserver observer)

Uses of CompletableObserver in io.reactivex.rxjava3.internal.jdk8

Classes in io.reactivex.rxjava3.internal.jdk8 that implement CompletableObserver

Modifier and Type	Class	Description
final class	CompletionStageConsumer<T>	Class that extends CompletableFuture and converts multiple types of reactive consumers and their signals into completion signals.

Methods in io.reactivex.rxjava3.internal.jdk8 with parameters of type CompletableObserver

Modifier and Type	Method	Description
protected void	CompletableFromCompletionStage.subscribeActual(CompletableObserver observer)

Uses of CompletableObserver in io.reactivex.rxjava3.internal.observers

Classes in io.reactivex.rxjava3.internal.observers that implement CompletableObserver

Modifier and Type	Class	Description
final class	BlockingDisposableMultiObserver<T>	Blocks until the upstream terminates and dispatches the outcome to the actual observer.
final class	BlockingMultiObserver<T>	A combined Observer that awaits the success or error signal via a CountDownLatch.
final class	CallbackCompletableObserver
final class	DisposableAutoReleaseMultiObserver<T>	Wraps lambda callbacks and when the upstream terminates or this (Single | Maybe | Completable) observer gets disposed, removes itself from a CompositeDisposable.
final class	EmptyCompletableObserver
final class	FutureMultiObserver<T>	An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.
final class	SafeCompletableObserver	Wraps another CompletableObserver and catches exceptions thrown by its onSubscribe, onError or onComplete methods despite the protocol forbids it.

Methods in io.reactivex.rxjava3.internal.observers with parameters of type CompletableObserver

Modifier and Type	Method	Description
void	BlockingDisposableMultiObserver.blockingConsume(CompletableObserver observer)

Constructors in io.reactivex.rxjava3.internal.observers with parameters of type CompletableObserver

Modifier	Constructor	Description
	SafeCompletableObserver(CompletableObserver downstream)

Uses of CompletableObserver in io.reactivex.rxjava3.internal.operators.completable

Classes in io.reactivex.rxjava3.internal.operators.completable that implement CompletableObserver

Modifier and Type	Class	Description
final class	CompletableCache	Consume the upstream source exactly once and cache its terminal event.

Methods in io.reactivex.rxjava3.internal.operators.completable with parameters of type CompletableObserver

Modifier and Type	Method	Description
void	CompletableAmb.subscribeActual(CompletableObserver observer)
protected void	CompletableAndThenCompletable.subscribeActual(CompletableObserver observer)
protected void	CompletableCache.subscribeActual(CompletableObserver observer)
void	CompletableConcat.subscribeActual(CompletableObserver observer)
void	CompletableConcatArray.subscribeActual(CompletableObserver observer)
void	CompletableConcatIterable.subscribeActual(CompletableObserver observer)
protected void	CompletableCreate.subscribeActual(CompletableObserver observer)
protected void	CompletableDefer.subscribeActual(CompletableObserver observer)
protected void	CompletableDelay.subscribeActual(CompletableObserver observer)
protected void	CompletableDetach.subscribeActual(CompletableObserver observer)
protected void	CompletableDisposeOn.subscribeActual(CompletableObserver observer)
protected void	CompletableDoFinally.subscribeActual(CompletableObserver observer)
protected void	CompletableDoOnEvent.subscribeActual(CompletableObserver observer)
void	CompletableEmpty.subscribeActual(CompletableObserver observer)
protected void	CompletableError.subscribeActual(CompletableObserver observer)
protected void	CompletableErrorSupplier.subscribeActual(CompletableObserver observer)
protected void	CompletableFromAction.subscribeActual(CompletableObserver observer)
protected void	CompletableFromCallable.subscribeActual(CompletableObserver observer)
protected void	CompletableFromObservable.subscribeActual(CompletableObserver observer)
protected void	CompletableFromPublisher.subscribeActual(CompletableObserver downstream)
protected void	CompletableFromRunnable.subscribeActual(CompletableObserver observer)
protected void	CompletableFromSingle.subscribeActual(CompletableObserver observer)
protected void	CompletableFromSupplier.subscribeActual(CompletableObserver observer)
protected void	CompletableFromUnsafeSource.subscribeActual(CompletableObserver observer)
protected void	CompletableHide.subscribeActual(CompletableObserver observer)
protected void	CompletableLift.subscribeActual(CompletableObserver observer)
void	CompletableMerge.subscribeActual(CompletableObserver observer)
void	CompletableMergeArray.subscribeActual(CompletableObserver observer)
void	CompletableMergeArrayDelayError.subscribeActual(CompletableObserver observer)
void	CompletableMergeDelayErrorIterable.subscribeActual(CompletableObserver observer)
void	CompletableMergeIterable.subscribeActual(CompletableObserver observer)
protected void	CompletableNever.subscribeActual(CompletableObserver observer)
protected void	CompletableObserveOn.subscribeActual(CompletableObserver observer)
protected void	CompletableOnErrorComplete.subscribeActual(CompletableObserver observer)
protected void	CompletablePeek.subscribeActual(CompletableObserver observer)
protected void	CompletableResumeNext.subscribeActual(CompletableObserver observer)
protected void	CompletableSubscribeOn.subscribeActual(CompletableObserver observer)
protected void	CompletableTakeUntilCompletable.subscribeActual(CompletableObserver observer)
void	CompletableTimeout.subscribeActual(CompletableObserver observer)
protected void	CompletableTimer.subscribeActual(CompletableObserver observer)
protected void	CompletableUsing.subscribeActual(CompletableObserver observer)

Uses of CompletableObserver in io.reactivex.rxjava3.internal.operators.flowable

Classes in io.reactivex.rxjava3.internal.operators.flowable that implement CompletableObserver

Modifier and Type	Class	Description
static final class	FlowableFromCompletable.FromCompletableObserver<T>

Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type CompletableObserver

Modifier and Type	Method	Description
protected void	FlowableFlatMapCompletableCompletable.subscribeActual(CompletableObserver observer)
protected void	FlowableIgnoreElementsCompletable.subscribeActual(CompletableObserver t)

Uses of CompletableObserver in io.reactivex.rxjava3.internal.operators.maybe

Methods in io.reactivex.rxjava3.internal.operators.maybe with parameters of type CompletableObserver

Modifier and Type	Method	Description
protected void	MaybeFlatMapCompletable.subscribeActual(CompletableObserver observer)
protected void	MaybeIgnoreElementCompletable.subscribeActual(CompletableObserver observer)

Uses of CompletableObserver in io.reactivex.rxjava3.internal.operators.mixed

Classes in io.reactivex.rxjava3.internal.operators.mixed that implement CompletableObserver

Modifier and Type	Class	Description
final class	MaterializeSingleObserver<T>	A consumer that implements the consumer types of Maybe, Single and Completable and turns their signals into Notifications for a SingleObserver.

Methods in io.reactivex.rxjava3.internal.operators.mixed with parameters of type CompletableObserver

Modifier and Type	Method	Description
protected void	FlowableConcatMapCompletable.subscribeActual(CompletableObserver observer)
protected void	FlowableSwitchMapCompletable.subscribeActual(CompletableObserver observer)
protected void	FlowableSwitchMapCompletablePublisher.subscribeActual(CompletableObserver observer)
protected void	ObservableConcatMapCompletable.subscribeActual(CompletableObserver observer)
protected void	ObservableSwitchMapCompletable.subscribeActual(CompletableObserver observer)

Uses of CompletableObserver in io.reactivex.rxjava3.internal.operators.observable

Classes in io.reactivex.rxjava3.internal.operators.observable that implement CompletableObserver

Modifier and Type	Class	Description
static final class	ObservableFromCompletable.FromCompletableObserver<T>

Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type CompletableObserver

Modifier and Type	Method	Description
protected void	ObservableFlatMapCompletableCompletable.subscribeActual(CompletableObserver observer)
void	ObservableIgnoreElementsCompletable.subscribeActual(CompletableObserver t)

Uses of CompletableObserver in io.reactivex.rxjava3.internal.operators.single

Methods in io.reactivex.rxjava3.internal.operators.single with parameters of type CompletableObserver

Modifier and Type	Method	Description
protected void	SingleFlatMapCompletable.subscribeActual(CompletableObserver observer)

Uses of CompletableObserver in io.reactivex.rxjava3.internal.util

Classes in io.reactivex.rxjava3.internal.util that implement CompletableObserver

Modifier and Type	Class	Description
enum	EmptyComponent	Singleton implementing many interfaces as empty.

Methods in io.reactivex.rxjava3.internal.util with parameters of type CompletableObserver

Modifier and Type	Method	Description
void	AtomicThrowable.tryTerminateConsumer(CompletableObserver consumer)	Tries to terminate this atomic throwable (by swapping in the TERMINATED indicator) and notifies the consumer if there was no error (onComplete) or there was a non-null, non-indicator exception contained before (onError).

Uses of CompletableObserver in io.reactivex.rxjava3.observers

Classes in io.reactivex.rxjava3.observers that implement CompletableObserver

Modifier and Type	Class	Description
class	DisposableCompletableObserver	An abstract CompletableObserver that allows asynchronous cancellation by implementing Disposable.
class	ResourceCompletableObserver	An abstract CompletableObserver that allows asynchronous cancellation of its subscription and associated resources.
class	TestObserver<T>	An Observer, MaybeObserver, SingleObserver and CompletableObserver composite that can record events from Observables, Maybes, Singles and Completables and allows making assertions about them.

Uses of CompletableObserver in io.reactivex.rxjava3.plugins

Methods in io.reactivex.rxjava3.plugins that return CompletableObserver

Modifier and Type	Method	Description
static @NonNull CompletableObserver	RxJavaPlugins.onSubscribe(@NonNull Completable source, @NonNull CompletableObserver observer)	Calls the associated hook function.

Methods in io.reactivex.rxjava3.plugins that return types with arguments of type CompletableObserver

Modifier and Type	Method	Description
static @Nullable BiFunction<? super Completable, @NonNull ? super CompletableObserver, @NonNull ? extends CompletableObserver>	RxJavaPlugins.getOnCompletableSubscribe()	Returns the current hook function.
static @Nullable BiFunction<? super Completable, @NonNull ? super CompletableObserver, @NonNull ? extends CompletableObserver>	RxJavaPlugins.getOnCompletableSubscribe()	Returns the current hook function.

Methods in io.reactivex.rxjava3.plugins with parameters of type CompletableObserver

Modifier and Type	Method	Description
static @NonNull CompletableObserver	RxJavaPlugins.onSubscribe(@NonNull Completable source, @NonNull CompletableObserver observer)	Calls the associated hook function.

Method parameters in io.reactivex.rxjava3.plugins with type arguments of type CompletableObserver

Modifier and Type	Method	Description
static void	RxJavaPlugins.setOnCompletableSubscribe(@Nullable BiFunction<? super Completable, @NonNull ? super CompletableObserver, @NonNull ? extends CompletableObserver> onCompletableSubscribe)	Sets the specific hook function.
static void	RxJavaPlugins.setOnCompletableSubscribe(@Nullable BiFunction<? super Completable, @NonNull ? super CompletableObserver, @NonNull ? extends CompletableObserver> onCompletableSubscribe)	Sets the specific hook function.

Uses of CompletableObserver in io.reactivex.rxjava3.subjects

Classes in io.reactivex.rxjava3.subjects that implement CompletableObserver

Modifier and Type	Class	Description
final class	CompletableSubject	Represents a hot Completable-like source and consumer of events similar to Subjects.

Methods in io.reactivex.rxjava3.subjects with parameters of type CompletableObserver

Modifier and Type	Method	Description
protected void	CompletableSubject.subscribeActual(CompletableObserver observer)