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.schedulers
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 onSubscribe(Disposable), onError(Throwable) or 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.

Fields in io.reactivex.rxjava3.internal.jdk8 declared as CompletableObserver

Modifier and Type	Field	Description
(package private) final CompletableObserver	CompletableFromCompletionStage.CompletionStageHandler.downstream

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

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

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

Modifier	Constructor	Description
(package private)	CompletionStageHandler(CompletableObserver downstream, FlowableFromCompletionStage.BiConsumerAtomicReference<T> whenReference)

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.

Fields in io.reactivex.rxjava3.internal.observers declared as CompletableObserver

Modifier and Type	Field	Description
(package private) final CompletableObserver	SafeCompletableObserver.downstream

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
(package private) static final class	CompletableAmb.Amb
(package private) static final class	CompletableAndThenCompletable.NextObserver
(package private) static final class	CompletableAndThenCompletable.SourceObserver
final class	CompletableCache	Consume the upstream source exactly once and cache its terminal event.
(package private) static final class	CompletableConcat.CompletableConcatSubscriber.ConcatInnerObserver
(package private) static final class	CompletableConcatArray.ConcatInnerObserver
(package private) static final class	CompletableConcatIterable.ConcatInnerObserver
(package private) static final class	CompletableDelay.Delay
(package private) static final class	CompletableDetach.DetachCompletableObserver
(package private) static final class	CompletableDisposeOn.DisposeOnObserver
(package private) static final class	CompletableDoFinally.DoFinallyObserver
(package private) final class	CompletableDoOnEvent.DoOnEvent
(package private) static final class	CompletableHide.HideCompletableObserver
(package private) final class	CompletableMerge.CompletableMergeSubscriber.MergeInnerObserver
(package private) static final class	CompletableMergeArray.InnerCompletableObserver
(package private) static final class	CompletableMergeArrayDelayError.MergeInnerCompletableObserver
(package private) static final class	CompletableMergeIterable.MergeCompletableObserver
(package private) static final class	CompletableObserveOn.ObserveOnCompletableObserver
(package private) static final class	CompletableOnErrorComplete.OnError
(package private) static final class	CompletableOnErrorReturn.OnErrorReturnMaybeObserver<T>
(package private) final class	CompletablePeek.CompletableObserverImplementation
(package private) static final class	CompletableResumeNext.ResumeNextObserver
(package private) static final class	CompletableSubscribeOn.SubscribeOnObserver
(package private) static final class	CompletableTakeUntilCompletable.TakeUntilMainObserver
(package private) static final class	CompletableTakeUntilCompletable.TakeUntilMainObserver.OtherObserver
(package private) final class	CompletableTimeout.DisposeTask.DisposeObserver
(package private) static final class	CompletableTimeout.TimeOutObserver
(package private) final class	CompletableToSingle.ToSingle
(package private) static final class	CompletableUsing.UsingObserver<R>

Fields in io.reactivex.rxjava3.internal.operators.completable declared as CompletableObserver

Modifier and Type	Field	Description
(package private) final CompletableObserver	CompletableAndThenCompletable.SourceObserver.actualObserver
(package private) final CompletableObserver	CompletableFromObservable.CompletableFromObservableObserver.co
(package private) final CompletableObserver	CompletableFromSingle.CompletableFromSingleObserver.co
(package private) final CompletableObserver	CompletableAmb.Amb.downstream
(package private) final CompletableObserver	CompletableAndThenCompletable.NextObserver.downstream
(package private) final CompletableObserver	CompletableCache.InnerCompletableCache.downstream
(package private) final CompletableObserver	CompletableConcat.CompletableConcatSubscriber.downstream
(package private) final CompletableObserver	CompletableConcatArray.ConcatInnerObserver.downstream
(package private) final CompletableObserver	CompletableConcatIterable.ConcatInnerObserver.downstream
(package private) final CompletableObserver	CompletableCreate.Emitter.downstream
(package private) final CompletableObserver	CompletableDelay.Delay.downstream
(package private) CompletableObserver	CompletableDetach.DetachCompletableObserver.downstream
(package private) final CompletableObserver	CompletableDisposeOn.DisposeOnObserver.downstream
(package private) final CompletableObserver	CompletableDoFinally.DoFinallyObserver.downstream
(package private) final CompletableObserver	CompletableFromPublisher.FromPublisherSubscriber.downstream
(package private) final CompletableObserver	CompletableHide.HideCompletableObserver.downstream
(package private) final CompletableObserver	CompletableMerge.CompletableMergeSubscriber.downstream
(package private) final CompletableObserver	CompletableMergeArray.InnerCompletableObserver.downstream
(package private) final CompletableObserver	CompletableMergeArrayDelayError.MergeInnerCompletableObserver.downstream
(package private) final CompletableObserver	CompletableMergeIterable.MergeCompletableObserver.downstream
(package private) final CompletableObserver	CompletableObserveOn.ObserveOnCompletableObserver.downstream
private final CompletableObserver	CompletableOnErrorComplete.OnError.downstream
(package private) final CompletableObserver	CompletablePeek.CompletableObserverImplementation.downstream
(package private) final CompletableObserver	CompletableResumeNext.ResumeNextObserver.downstream
(package private) final CompletableObserver	CompletableSubscribeOn.SubscribeOnObserver.downstream
(package private) final CompletableObserver	CompletableTakeUntilCompletable.TakeUntilMainObserver.downstream
(package private) final CompletableObserver	CompletableTimeout.DisposeTask.downstream
private final CompletableObserver	CompletableTimeout.TimeOutObserver.downstream
(package private) final CompletableObserver	CompletableTimer.TimerDisposable.downstream
(package private) final CompletableObserver	CompletableUsing.UsingObserver.downstream
private final CompletableObserver	CompletableDoOnEvent.DoOnEvent.observer

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)

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

Modifier	Constructor	Description
(package private)	Amb(AtomicBoolean once, CompositeDisposable set, CompletableObserver observer)
(package private)	CompletableConcatSubscriber(CompletableObserver actual, int prefetch)
(package private)	CompletableFromObservableObserver(CompletableObserver co)
(package private)	CompletableFromSingleObserver(CompletableObserver co)
(package private)	CompletableMergeSubscriber(CompletableObserver actual, int maxConcurrency, boolean delayErrors)
(package private)	CompletableObserverImplementation(CompletableObserver downstream)
(package private)	ConcatInnerObserver(CompletableObserver actual, CompletableSource[] sources)
(package private)	ConcatInnerObserver(CompletableObserver actual, Iterator<? extends CompletableSource> sources)
(package private)	Delay(CompletableObserver downstream, long delay, TimeUnit unit, Scheduler scheduler, boolean delayError)
(package private)	DetachCompletableObserver(CompletableObserver downstream)
(package private)	DisposeOnObserver(CompletableObserver observer, Scheduler scheduler)
(package private)	DisposeTask(AtomicBoolean once, CompositeDisposable set, CompletableObserver observer)
(package private)	DoFinallyObserver(CompletableObserver actual, Action onFinally)
(package private)	DoOnEvent(CompletableObserver observer)
(package private)	Emitter(CompletableObserver downstream)
(package private)	FromPublisherSubscriber(CompletableObserver downstream)
(package private)	HideCompletableObserver(CompletableObserver downstream)
(package private)	InnerCompletableCache(CompletableObserver downstream)
(package private)	InnerCompletableObserver(CompletableObserver actual, AtomicBoolean once, CompositeDisposable set, int n)
(package private)	MergeCompletableObserver(CompletableObserver actual, CompositeDisposable set, AtomicInteger wip)
(package private)	MergeInnerCompletableObserver(CompletableObserver observer, CompositeDisposable set, AtomicThrowable error, AtomicInteger wip)
(package private)	NextObserver(AtomicReference<Disposable> parent, CompletableObserver downstream)
(package private)	ObserveOnCompletableObserver(CompletableObserver actual, Scheduler scheduler)
(package private)	OnError(CompletableObserver observer, Predicate<? super Throwable> predicate)
(package private)	ResumeNextObserver(CompletableObserver observer, Function<? super Throwable,? extends CompletableSource> errorMapper)
(package private)	SourceObserver(CompletableObserver actualObserver, CompletableSource next)
(package private)	SubscribeOnObserver(CompletableObserver actual, CompletableSource source)
(package private)	TakeUntilMainObserver(CompletableObserver downstream)
(package private)	TimeOutObserver(CompositeDisposable set, AtomicBoolean once, CompletableObserver observer)
(package private)	TimerDisposable(CompletableObserver downstream)
(package private)	UsingObserver(CompletableObserver actual, R resource, Consumer<? super R> disposer, boolean eager)

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
(package private) static final class	FlowableConcatWithCompletable.ConcatWithSubscriber<T>
(package private) final class	FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber.InnerConsumer
(package private) final class	FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber.InnerObserver
static final class	FlowableFromCompletable.FromCompletableObserver<T>
(package private) static final class	FlowableMergeWithCompletable.MergeWithSubscriber.OtherObserver

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as CompletableObserver

Modifier and Type	Field	Description
(package private) final CompletableObserver	FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber.downstream
(package private) final CompletableObserver	FlowableIgnoreElementsCompletable.IgnoreElementsSubscriber.downstream

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)

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

Modifier	Constructor	Description
(package private)	FlatMapCompletableMainSubscriber(CompletableObserver observer, Function<? super T,? extends CompletableSource> mapper, boolean delayErrors, int maxConcurrency)
(package private)	IgnoreElementsSubscriber(CompletableObserver downstream)

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

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

Modifier and Type	Class	Description
(package private) static final class	MaybeDelayWithCompletable.OtherObserver<T>
(package private) static final class	MaybeFlatMapCompletable.FlatMapCompletableObserver<T>
(package private) static final class	MaybeFromCompletable.FromCompletableObserver<T>

Fields in io.reactivex.rxjava3.internal.operators.maybe declared as CompletableObserver

Modifier and Type	Field	Description
(package private) final CompletableObserver	MaybeFlatMapCompletable.FlatMapCompletableObserver.downstream
(package private) final CompletableObserver	MaybeIgnoreElementCompletable.IgnoreMaybeObserver.downstream

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)

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

Modifier	Constructor	Description
(package private)	FlatMapCompletableObserver(CompletableObserver actual, Function<? super T,? extends CompletableSource> mapper)
(package private)	IgnoreMaybeObserver(CompletableObserver downstream)

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
(package private) static final class	CompletableAndThenObservable.AndThenObservableObserver<R>
(package private) static final class	CompletableAndThenPublisher.AndThenPublisherSubscriber<R>
(package private) static final class	FlowableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver
(package private) static final class	FlowableSwitchMapCompletable.SwitchMapCompletableObserver.SwitchMapInnerObserver
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.
(package private) static final class	ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver
(package private) static final class	ObservableSwitchMapCompletable.SwitchMapCompletableObserver.SwitchMapInnerObserver

Fields in io.reactivex.rxjava3.internal.operators.mixed declared as CompletableObserver

Modifier and Type	Field	Description
(package private) final CompletableObserver	FlowableConcatMapCompletable.ConcatMapCompletableObserver.downstream
(package private) final CompletableObserver	FlowableSwitchMapCompletable.SwitchMapCompletableObserver.downstream
(package private) final CompletableObserver	ObservableConcatMapCompletable.ConcatMapCompletableObserver.downstream
(package private) final CompletableObserver	ObservableSwitchMapCompletable.SwitchMapCompletableObserver.downstream

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)
(package private) static <T> boolean	ScalarXMapZHelper.tryAsCompletable(Object source, Function<? super T,? extends CompletableSource> mapper, CompletableObserver observer)	Try subscribing to a CompletableSource mapped from a scalar source (which implements Supplier).

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

Modifier	Constructor	Description
(package private)	ConcatMapCompletableObserver(CompletableObserver downstream, Function<? super T,? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)
(package private)	ConcatMapCompletableObserver(CompletableObserver downstream, Function<? super T,? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)
(package private)	SwitchMapCompletableObserver(CompletableObserver downstream, Function<? super T,? extends CompletableSource> mapper, boolean delayErrors)
(package private)	SwitchMapCompletableObserver(CompletableObserver downstream, Function<? super T,? extends CompletableSource> mapper, boolean delayErrors)

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
(package private) static final class	ObservableConcatWithCompletable.ConcatWithObserver<T>
(package private) final class	ObservableFlatMapCompletable.FlatMapCompletableMainObserver.InnerObserver
(package private) final class	ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver.InnerObserver
static final class	ObservableFromCompletable.FromCompletableObserver<T>
(package private) static final class	ObservableMergeWithCompletable.MergeWithObserver.OtherObserver

Fields in io.reactivex.rxjava3.internal.operators.observable declared as CompletableObserver

Modifier and Type	Field	Description
(package private) final CompletableObserver	ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver.downstream
(package private) final CompletableObserver	ObservableIgnoreElementsCompletable.IgnoreObservable.downstream

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)

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

Modifier	Constructor	Description
(package private)	FlatMapCompletableMainObserver(CompletableObserver observer, Function<? super T,? extends CompletableSource> mapper, boolean delayErrors)
(package private)	IgnoreObservable(CompletableObserver t)

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

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

Modifier and Type	Class	Description
(package private) static final class	SingleDelayWithCompletable.OtherObserver<T>
(package private) static final class	SingleFlatMapCompletable.FlatMapCompletableObserver<T>

Fields in io.reactivex.rxjava3.internal.operators.single declared as CompletableObserver

Modifier and Type	Field	Description
(package private) final CompletableObserver	SingleFlatMapCompletable.FlatMapCompletableObserver.downstream

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

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

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

Modifier	Constructor	Description
(package private)	FlatMapCompletableObserver(CompletableObserver actual, Function<? super T,? extends CompletableSource> mapper)

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

Fields in io.reactivex.rxjava3.internal.schedulers declared as CompletableObserver

Modifier and Type	Field	Description
(package private) final CompletableObserver	SchedulerWhen.OnCompletedAction.actionCompletable

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

Modifier and Type	Method	Description
(package private) void	SchedulerWhen.ScheduledAction.call(Scheduler.Worker actualWorker, CompletableObserver actionCompletable)
protected Disposable	SchedulerWhen.DelayedAction.callActual(Scheduler.Worker actualWorker, CompletableObserver actionCompletable)
protected Disposable	SchedulerWhen.ImmediateAction.callActual(Scheduler.Worker actualWorker, CompletableObserver actionCompletable)
protected abstract Disposable	SchedulerWhen.ScheduledAction.callActual(Scheduler.Worker actualWorker, CompletableObserver actionCompletable)
protected void	SchedulerWhen.CreateWorkerFunction.WorkerCompletable.subscribeActual(CompletableObserver actionCompletable)

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

Modifier	Constructor	Description
(package private)	OnCompletedAction(Runnable action, CompletableObserver actionCompletable)

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

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

Modifier and Type	Field	Description
(package private) static @Nullable BiFunction<? super Completable,@NonNull ? super CompletableObserver,@NonNull ? extends CompletableObserver>	RxJavaPlugins.onCompletableSubscribe
(package private) static @Nullable BiFunction<? super Completable,@NonNull ? super CompletableObserver,@NonNull ? extends CompletableObserver>	RxJavaPlugins.onCompletableSubscribe

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.

Fields in io.reactivex.rxjava3.subjects declared as CompletableObserver

Modifier and Type	Field	Description
(package private) final CompletableObserver	CompletableSubject.CompletableDisposable.downstream

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

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

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

Modifier	Constructor	Description
(package private)	CompletableDisposable(CompletableObserver actual, CompletableSubject parent)