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
<@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.
void	Completable.blockingSubscribe(@NonNull CompletableObserver observer)	Subscribes to the current Completable and calls the appropriate CompletableObserver method on the current thread.
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).
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(java.lang.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
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) 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

Constructor	Description
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
class	BlockingDisposableMultiObserver<T>	Blocks until the upstream terminates and dispatches the outcome to the actual observer.
class	BlockingMultiObserver<T>	A combined Observer that awaits the success or error signal via a CountDownLatch.
class	CallbackCompletableObserver
class	DisposableAutoReleaseMultiObserver<T>	Wraps lambda callbacks and when the upstream terminates or this (Single | Maybe | Completable) observer gets disposed, removes itself from a CompositeDisposable.
class	EmptyCompletableObserver
class	FutureMultiObserver<T>	An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.
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) 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

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

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

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

Constructor	Description
Amb(java.util.concurrent.atomic.AtomicBoolean once, CompositeDisposable set, CompletableObserver observer)
CompletableConcatSubscriber(CompletableObserver actual, int prefetch)
CompletableFromObservableObserver(CompletableObserver co)
CompletableFromSingleObserver(CompletableObserver co)
CompletableMergeSubscriber(CompletableObserver actual, int maxConcurrency, boolean delayErrors)
CompletableObserverImplementation(CompletableObserver downstream)
ConcatInnerObserver(CompletableObserver actual, CompletableSource[] sources)
ConcatInnerObserver(CompletableObserver actual, java.util.Iterator<? extends CompletableSource> sources)
Delay(CompletableObserver downstream, long delay, java.util.concurrent.TimeUnit unit, Scheduler scheduler, boolean delayError)
DetachCompletableObserver(CompletableObserver downstream)
DisposeOnObserver(CompletableObserver observer, Scheduler scheduler)
DisposeTask(java.util.concurrent.atomic.AtomicBoolean once, CompositeDisposable set, CompletableObserver observer)
DoFinallyObserver(CompletableObserver actual, Action onFinally)
DoOnEvent(CompletableObserver observer)
Emitter(CompletableObserver downstream)
FromPublisherSubscriber(CompletableObserver downstream)
HideCompletableObserver(CompletableObserver downstream)
InnerCompletableCache(CompletableObserver downstream)
InnerCompletableObserver(CompletableObserver actual, java.util.concurrent.atomic.AtomicBoolean once, CompositeDisposable set, int n)
MergeCompletableObserver(CompletableObserver actual, CompositeDisposable set, java.util.concurrent.atomic.AtomicInteger wip)
MergeInnerCompletableObserver(CompletableObserver observer, CompositeDisposable set, AtomicThrowable error, java.util.concurrent.atomic.AtomicInteger wip)
NextObserver(java.util.concurrent.atomic.AtomicReference<Disposable> parent, CompletableObserver downstream)
ObserveOnCompletableObserver(CompletableObserver actual, Scheduler scheduler)
OnError(CompletableObserver observer, Predicate<? super java.lang.Throwable> predicate)
ResumeNextObserver(CompletableObserver observer, Function<? super java.lang.Throwable,? extends CompletableSource> errorMapper)
SourceObserver(CompletableObserver actualObserver, CompletableSource next)
SubscribeOnObserver(CompletableObserver actual, CompletableSource source)
TakeUntilMainObserver(CompletableObserver downstream)
TimeOutObserver(CompositeDisposable set, java.util.concurrent.atomic.AtomicBoolean once, CompletableObserver observer)
TimerDisposable(CompletableObserver downstream)
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 class	FlowableConcatWithCompletable.ConcatWithSubscriber<T>
(package private) class	FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber.InnerConsumer
(package private) class	FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber.InnerObserver
static class	FlowableFromCompletable.FromCompletableObserver<T>
(package private) static class	FlowableMergeWithCompletable.MergeWithSubscriber.OtherObserver

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

Modifier and Type	Field	Description
(package private) CompletableObserver	FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber.downstream
(package private) 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

Constructor	Description
FlatMapCompletableMainSubscriber(CompletableObserver observer, Function<? super T,? extends CompletableSource> mapper, boolean delayErrors, int maxConcurrency)
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 class	MaybeDelayWithCompletable.OtherObserver<T>
(package private) static class	MaybeFlatMapCompletable.FlatMapCompletableObserver<T>
(package private) static class	MaybeFromCompletable.FromCompletableObserver<T>

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

Modifier and Type	Field	Description
(package private) CompletableObserver	MaybeFlatMapCompletable.FlatMapCompletableObserver.downstream
(package private) 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

Constructor	Description
FlatMapCompletableObserver(CompletableObserver actual, Function<? super T,? extends CompletableSource> mapper)
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 class	CompletableAndThenObservable.AndThenObservableObserver<R>
(package private) static class	CompletableAndThenPublisher.AndThenPublisherSubscriber<R>
(package private) static class	FlowableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver
(package private) static class	FlowableSwitchMapCompletable.SwitchMapCompletableObserver.SwitchMapInnerObserver
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 class	ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver
(package private) static class	ObservableSwitchMapCompletable.SwitchMapCompletableObserver.SwitchMapInnerObserver

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

Modifier and Type	Field	Description
(package private) CompletableObserver	FlowableConcatMapCompletable.ConcatMapCompletableObserver.downstream
(package private) CompletableObserver	FlowableSwitchMapCompletable.SwitchMapCompletableObserver.downstream
(package private) CompletableObserver	ObservableConcatMapCompletable.ConcatMapCompletableObserver.downstream
(package private) 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(java.lang.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

Constructor	Description
ConcatMapCompletableObserver(CompletableObserver downstream, Function<? super T,? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)
ConcatMapCompletableObserver(CompletableObserver downstream, Function<? super T,? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)
SwitchMapCompletableObserver(CompletableObserver downstream, Function<? super T,? extends CompletableSource> mapper, boolean delayErrors)
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 class	ObservableConcatWithCompletable.ConcatWithObserver<T>
(package private) class	ObservableFlatMapCompletable.FlatMapCompletableMainObserver.InnerObserver
(package private) class	ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver.InnerObserver
static class	ObservableFromCompletable.FromCompletableObserver<T>
(package private) static class	ObservableMergeWithCompletable.MergeWithObserver.OtherObserver

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

Modifier and Type	Field	Description
(package private) CompletableObserver	ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver.downstream
(package private) 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

Constructor	Description
FlatMapCompletableMainObserver(CompletableObserver observer, Function<? super T,? extends CompletableSource> mapper, boolean delayErrors)
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 class	SingleDelayWithCompletable.OtherObserver<T>
(package private) static class	SingleFlatMapCompletable.FlatMapCompletableObserver<T>

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

Modifier and Type	Field	Description
(package private) 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

Constructor	Description
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) 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

Constructor	Description
OnCompletedAction(java.lang.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
class	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,? super CompletableObserver,? extends CompletableObserver>	RxJavaPlugins.onCompletableSubscribe
(package private) static @Nullable BiFunction<? super Completable,? super CompletableObserver,? 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,? super CompletableObserver,? extends CompletableObserver>	RxJavaPlugins.getOnCompletableSubscribe()	Returns the current hook function.
static @Nullable BiFunction<? super Completable,? super CompletableObserver,? 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,? super CompletableObserver,? extends CompletableObserver> onCompletableSubscribe)	Sets the specific hook function.
static void	RxJavaPlugins.setOnCompletableSubscribe(@Nullable BiFunction<? super Completable,? super CompletableObserver,? 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
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) 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

Constructor	Description
CompletableDisposable(CompletableObserver actual, CompletableSubject parent)