Uses of Interface
io.reactivex.rxjava3.core.CompletableObserver
Packages that use CompletableObserver
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.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.Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.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 CompletableObserverModifier and TypeMethodDescriptionfinal <@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 CompletableObserverModifier and TypeMethodDescriptionCompletableOperator.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 CompletableObserverModifier and TypeMethodDescriptionCompletableOperator.apply
(@NonNull CompletableObserver observer) Applies a function to the childCompletableObserver
and returns a new parentCompletableObserver
.final void
Completable.blockingSubscribe
(@NonNull CompletableObserver observer) Subscribes to the currentCompletable
and calls the appropriateCompletableObserver
method on the current thread.final 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)
.final 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 CompletableObserverModifier and TypeMethodDescriptionstatic 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 CompletableObserverModifier and TypeClassDescriptionfinal class
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 CompletableObserverModifier and TypeFieldDescription(package private) final CompletableObserver
CompletableFromCompletionStage.CompletionStageHandler.downstream
Methods in io.reactivex.rxjava3.internal.jdk8 with parameters of type CompletableObserverModifier and TypeMethodDescriptionprotected void
CompletableFromCompletionStage.subscribeActual
(CompletableObserver observer) Constructors in io.reactivex.rxjava3.internal.jdk8 with parameters of type CompletableObserverModifierConstructorDescription(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 CompletableObserverModifier and TypeClassDescriptionfinal class
Blocks until the upstream terminates and dispatches the outcome to the actual observer.final class
A combined Observer that awaits the success or error signal via a CountDownLatch.final class
final class
Wraps lambda callbacks and when the upstream terminates or this (Single | Maybe | Completable) observer gets disposed, removes itself from aCompositeDisposable
.final class
final class
An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.final class
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 CompletableObserverModifier and TypeFieldDescription(package private) final CompletableObserver
SafeCompletableObserver.downstream
Methods in io.reactivex.rxjava3.internal.observers with parameters of type CompletableObserverModifier and TypeMethodDescriptionvoid
BlockingDisposableMultiObserver.blockingConsume
(CompletableObserver observer) Constructors in io.reactivex.rxjava3.internal.observers with parameters of type CompletableObserver -
Uses of CompletableObserver in io.reactivex.rxjava3.internal.operators.completable
Classes in io.reactivex.rxjava3.internal.operators.completable that implement CompletableObserverModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
final class
Consume the upstream source exactly once and cache its terminal event.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.completable declared as CompletableObserverModifier and TypeFieldDescription(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 CompletableObserverModifier and TypeMethodDescriptionvoid
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 CompletableObserverModifierConstructorDescription(package private)
Amb
(AtomicBoolean once, CompositeDisposable set, CompletableObserver observer) (package private)
CompletableConcatSubscriber
(CompletableObserver actual, int prefetch) (package private)
(package private)
(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 CompletableObserverModifier and TypeClassDescription(package private) static final class
(package private) final class
(package private) final class
static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as CompletableObserverModifier and TypeFieldDescription(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 CompletableObserverModifier and TypeMethodDescriptionprotected void
FlowableFlatMapCompletableCompletable.subscribeActual
(CompletableObserver observer) protected void
FlowableIgnoreElementsCompletable.subscribeActual
(CompletableObserver t) Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type CompletableObserverModifierConstructorDescription(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 CompletableObserverModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.maybe declared as CompletableObserverModifier and TypeFieldDescription(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 CompletableObserverModifier and TypeMethodDescriptionprotected void
MaybeFlatMapCompletable.subscribeActual
(CompletableObserver observer) protected void
MaybeIgnoreElementCompletable.subscribeActual
(CompletableObserver observer) Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type CompletableObserverModifierConstructorDescription(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 CompletableObserverModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
final class
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
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.mixed declared as CompletableObserverModifier and TypeFieldDescription(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 CompletableObserverModifier and TypeMethodDescriptionprotected 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 aCompletableSource
mapped from a scalar source (which implementsSupplier
).Constructors in io.reactivex.rxjava3.internal.operators.mixed with parameters of type CompletableObserverModifierConstructorDescription(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 CompletableObserverModifier and TypeClassDescription(package private) static final class
(package private) final class
(package private) final class
static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.observable declared as CompletableObserverModifier and TypeFieldDescription(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 CompletableObserverModifier and TypeMethodDescriptionprotected void
ObservableFlatMapCompletableCompletable.subscribeActual
(CompletableObserver observer) void
ObservableIgnoreElementsCompletable.subscribeActual
(CompletableObserver t) Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type CompletableObserverModifierConstructorDescription(package private)
FlatMapCompletableMainObserver
(CompletableObserver observer, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors) (package private)
-
Uses of CompletableObserver in io.reactivex.rxjava3.internal.operators.single
Classes in io.reactivex.rxjava3.internal.operators.single that implement CompletableObserverModifier and TypeClassDescription(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.single declared as CompletableObserverModifier and TypeFieldDescription(package private) final CompletableObserver
SingleFlatMapCompletable.FlatMapCompletableObserver.downstream
Methods in io.reactivex.rxjava3.internal.operators.single with parameters of type CompletableObserverModifier and TypeMethodDescriptionprotected void
SingleFlatMapCompletable.subscribeActual
(CompletableObserver observer) Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type CompletableObserverModifierConstructorDescription(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 CompletableObserverModifier and TypeFieldDescription(package private) final CompletableObserver
SchedulerWhen.OnCompletedAction.actionCompletable
Methods in io.reactivex.rxjava3.internal.schedulers with parameters of type CompletableObserverModifier and TypeMethodDescription(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 CompletableObserverModifierConstructorDescription(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 CompletableObserverModifier and TypeClassDescriptionenum
Singleton implementing many interfaces as empty.Methods in io.reactivex.rxjava3.internal.util with parameters of type CompletableObserverModifier and TypeMethodDescriptionvoid
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 CompletableObserverModifier and TypeClassDescriptionclass
An abstractCompletableObserver
that allows asynchronous cancellation by implementing Disposable.class
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 CompletableObserverModifier and TypeFieldDescription(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 CompletableObserverModifier and TypeMethodDescriptionstatic @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 CompletableObserverModifier and TypeMethodDescriptionstatic @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 CompletableObserverModifier and TypeMethodDescriptionstatic @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 CompletableObserverModifier and TypeMethodDescriptionstatic 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 CompletableObserverModifier and TypeClassDescriptionfinal class
Represents a hot Completable-like source and consumer of events similar to Subjects.Fields in io.reactivex.rxjava3.subjects declared as CompletableObserverModifier and TypeFieldDescription(package private) final CompletableObserver
CompletableSubject.CompletableDisposable.downstream
Methods in io.reactivex.rxjava3.subjects with parameters of type CompletableObserverModifier and TypeMethodDescriptionprotected void
CompletableSubject.subscribeActual
(CompletableObserver observer) Constructors in io.reactivex.rxjava3.subjects with parameters of type CompletableObserverModifierConstructorDescription(package private)
CompletableDisposable
(CompletableObserver actual, CompletableSubject parent)