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
andCompletable
; 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 theTestObserver
that allows unit testingObservable
-,Single
-,Maybe
- andCompletable
-based flows.io.reactivex.rxjava3.plugins Contains the central plugin handlerRxJavaPlugins
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>
ECompletable. subscribeWith(@NonNull E observer)
Subscribes a givenCompletableObserver
(subclass) to thisCompletable
and returns the givenCompletableObserver
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 childCompletableObserver
and returns a new parentCompletableObserver
.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 childCompletableObserver
and returns a new parentCompletableObserver
.void
Completable. blockingSubscribe(@NonNull CompletableObserver observer)
Subscribes to the currentCompletable
and calls the appropriateCompletableObserver
method on the current thread.void
Completable. safeSubscribe(@NonNull CompletableObserver observer)
Wraps the givenCompletableObserver
, catches anyRuntimeException
s thrown by itsonSubscribe(Disposable)
,onError(Throwable)
oronComplete()
methods and routes those to the global error handler viaRxJavaPlugins.onError(Throwable)
.void
Completable. subscribe(@NonNull CompletableObserver observer)
void
CompletableSource. subscribe(@NonNull CompletableObserver observer)
Subscribes the givenCompletableObserver
to thisCompletableSource
instance.protected abstract void
Completable. subscribeActual(@NonNull CompletableObserver observer)
Implement this method to handle the incomingCompletableObserver
s 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 aCompositeDisposable
.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 anotherCompletableObserver
and catches exceptions thrown by itsonSubscribe
,onError
oronComplete
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
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)
-
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 aCompletableSource
mapped from a scalar source (which implementsSupplier
).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 abstractCompletableObserver
that allows asynchronous cancellation by implementing Disposable.class
ResourceCompletableObserver
An abstractCompletableObserver
that allows asynchronous cancellation of its subscription and associated resources.class
TestObserver<T>
AnObserver
,MaybeObserver
,SingleObserver
andCompletableObserver
composite that can record events fromObservable
s,Maybe
s,Single
s andCompletable
s 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)
-