Uses of Interface
io.reactivex.rxjava3.core.SingleObserver
Packages that use SingleObserver
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 SingleObserver in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with type parameters of type SingleObserverModifier and TypeMethodDescriptionfinal <@NonNull E extends SingleObserver<? super @NonNull T>>
ESingle.subscribeWith
(@NonNull E observer) Subscribes a givenSingleObserver
(subclass) to thisSingle
and returns the givenSingleObserver
as is.Methods in io.reactivex.rxjava3.core that return SingleObserverModifier and TypeMethodDescription@NonNull SingleObserver
<? super Upstream> SingleOperator.apply
(@NonNull SingleObserver<? super @NonNull Downstream> observer) Applies a function to the childSingleObserver
and returns a new parentSingleObserver
.Methods in io.reactivex.rxjava3.core with parameters of type SingleObserverModifier and TypeMethodDescription@NonNull SingleObserver
<? super Upstream> SingleOperator.apply
(@NonNull SingleObserver<? super @NonNull Downstream> observer) Applies a function to the childSingleObserver
and returns a new parentSingleObserver
.final void
Single.blockingSubscribe
(@NonNull SingleObserver<? super @NonNull T> observer) Subscribes to the currentSingle
and calls the appropriateSingleObserver
method on the current thread.final void
Single.safeSubscribe
(@NonNull SingleObserver<? super @NonNull T> observer) Wraps the givenSingleObserver
, catches anyRuntimeException
s thrown by itsonSubscribe(Disposable)
,onSuccess(Object)
oronError(Throwable)
methods* and routes those to the global error handler viaRxJavaPlugins.onError(Throwable)
.final void
Single.subscribe
(@NonNull SingleObserver<? super @NonNull T> observer) void
SingleSource.subscribe
(@NonNull SingleObserver<? super @NonNull T> observer) Subscribes the givenSingleObserver
to thisSingleSource
instance.protected abstract void
Single.subscribeActual
(@NonNull SingleObserver<? super @NonNull T> observer) Implement this method in subclasses to handle the incomingSingleObserver
s. -
Uses of SingleObserver in io.reactivex.rxjava3.internal.disposables
Methods in io.reactivex.rxjava3.internal.disposables with parameters of type SingleObserverModifier and TypeMethodDescriptionstatic void
EmptyDisposable.error
(Throwable e, SingleObserver<?> observer) -
Uses of SingleObserver in io.reactivex.rxjava3.internal.jdk8
Classes in io.reactivex.rxjava3.internal.jdk8 that implement SingleObserverModifier and TypeClassDescriptionfinal class
Class that extends CompletableFuture and converts multiple types of reactive consumers and their signals into completion signals.(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.jdk8 declared as SingleObserverModifier and TypeFieldDescription(package private) final SingleObserver
<? super R> FlowableCollectWithCollectorSingle.CollectorSingleObserver.downstream
(package private) final SingleObserver
<? super R> ObservableCollectWithCollectorSingle.CollectorSingleObserver.downstream
(package private) final SingleObserver
<? super T> SingleFromCompletionStage.CompletionStageHandler.downstream
Methods in io.reactivex.rxjava3.internal.jdk8 with parameters of type SingleObserverModifier and TypeMethodDescriptionprotected void
FlowableCollectWithCollectorSingle.subscribeActual
(@NonNull SingleObserver<? super R> observer) protected void
ObservableCollectWithCollectorSingle.subscribeActual
(@NonNull SingleObserver<? super R> observer) protected void
SingleFromCompletionStage.subscribeActual
(SingleObserver<? super T> observer) Constructors in io.reactivex.rxjava3.internal.jdk8 with parameters of type SingleObserverModifierConstructorDescription(package private)
CollectorSingleObserver
(SingleObserver<? super R> downstream, A container, BiConsumer<A, T> accumulator, Function<A, R> finisher) (package private)
CollectorSingleObserver
(SingleObserver<? super R> downstream, A container, BiConsumer<A, T> accumulator, Function<A, R> finisher) (package private)
CompletionStageHandler
(SingleObserver<? super T> downstream, FlowableFromCompletionStage.BiConsumerAtomicReference<T> whenReference) -
Uses of SingleObserver in io.reactivex.rxjava3.internal.observers
Classes in io.reactivex.rxjava3.internal.observers that implement SingleObserverModifier and TypeClassDescriptionfinal class
final 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
An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.final class
A SingleObserver implementation used for subscribing to the actual SingleSource and replace the current Disposable in a parent AtomicReference.final class
Wraps anotherSingleObserver
and catches exceptions thrown by itsonSubscribe
,onSuccess
oronError
methods despite the protocol forbids it.Fields in io.reactivex.rxjava3.internal.observers declared as SingleObserverModifier and TypeFieldDescription(package private) final SingleObserver
<? super T> ResumeSingleObserver.downstream
(package private) final SingleObserver
<? super T> SafeSingleObserver.downstream
Methods in io.reactivex.rxjava3.internal.observers with parameters of type SingleObserverModifier and TypeMethodDescriptionvoid
BlockingDisposableMultiObserver.blockingConsume
(SingleObserver<? super T> observer) Constructors in io.reactivex.rxjava3.internal.observers with parameters of type SingleObserverModifierConstructorDescriptionResumeSingleObserver
(AtomicReference<Disposable> parent, SingleObserver<? super T> downstream) SafeSingleObserver
(SingleObserver<? super T> downstream) -
Uses of SingleObserver in io.reactivex.rxjava3.internal.operators.completable
Classes in io.reactivex.rxjava3.internal.operators.completable that implement SingleObserverModifier and TypeClassDescription(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.completable declared as SingleObserverModifier and TypeFieldDescriptionprivate final SingleObserver
<? super T> CompletableToSingle.ToSingle.observer
Methods in io.reactivex.rxjava3.internal.operators.completable with parameters of type SingleObserverModifier and TypeMethodDescriptionprotected void
CompletableMaterialize.subscribeActual
(SingleObserver<? super Notification<T>> observer) protected void
CompletableToSingle.subscribeActual
(SingleObserver<? super T> observer) Constructors in io.reactivex.rxjava3.internal.operators.completable with parameters of type SingleObserver -
Uses of SingleObserver in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement SingleObserverModifier and TypeClassDescription(package private) static final class
(package private) final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as SingleObserverModifier and TypeFieldDescription(package private) final SingleObserver
<? super Boolean> FlowableAllSingle.AllSubscriber.downstream
(package private) final SingleObserver
<? super Boolean> FlowableAnySingle.AnySubscriber.downstream
(package private) final SingleObserver
<? super U> FlowableCollectSingle.CollectSubscriber.downstream
(package private) final SingleObserver
<? super Long> FlowableCountSingle.CountSubscriber.downstream
(package private) final SingleObserver
<? super T> FlowableElementAtSingle.ElementAtSubscriber.downstream
(package private) final SingleObserver
<? super T> FlowableLastSingle.LastSubscriber.downstream
(package private) final SingleObserver
<? super R> FlowableReduceSeedSingle.ReduceSeedObserver.downstream
(package private) final SingleObserver
<? super Boolean> FlowableSequenceEqualSingle.EqualCoordinator.downstream
(package private) final SingleObserver
<? super T> FlowableSingleSingle.SingleElementSubscriber.downstream
(package private) final SingleObserver
<? super U> FlowableToListSingle.ToListSubscriber.downstream
Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type SingleObserverModifier and TypeMethodDescriptionprotected void
FlowableAllSingle.subscribeActual
(SingleObserver<? super Boolean> observer) protected void
FlowableAnySingle.subscribeActual
(SingleObserver<? super Boolean> observer) protected void
FlowableCollectSingle.subscribeActual
(SingleObserver<? super U> observer) protected void
FlowableCountSingle.subscribeActual
(SingleObserver<? super Long> observer) protected void
FlowableElementAtSingle.subscribeActual
(SingleObserver<? super T> observer) protected void
FlowableLastSingle.subscribeActual
(SingleObserver<? super T> observer) protected void
FlowableReduceSeedSingle.subscribeActual
(SingleObserver<? super R> observer) protected void
FlowableReduceWithSingle.subscribeActual
(SingleObserver<? super R> observer) void
FlowableSequenceEqualSingle.subscribeActual
(SingleObserver<? super Boolean> observer) protected void
FlowableSingleSingle.subscribeActual
(SingleObserver<? super T> observer) protected void
FlowableToListSingle.subscribeActual
(SingleObserver<? super U> observer) Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type SingleObserverModifierConstructorDescription(package private)
AllSubscriber
(SingleObserver<? super Boolean> actual, Predicate<? super T> predicate) (package private)
AnySubscriber
(SingleObserver<? super Boolean> actual, Predicate<? super T> predicate) (package private)
CollectSubscriber
(SingleObserver<? super U> actual, U u, BiConsumer<? super U, ? super T> collector) (package private)
CountSubscriber
(SingleObserver<? super Long> downstream) (package private)
ElementAtSubscriber
(SingleObserver<? super T> actual, long index, T defaultValue) (package private)
EqualCoordinator
(SingleObserver<? super Boolean> actual, int prefetch, BiPredicate<? super T, ? super T> comparer) (package private)
LastSubscriber
(SingleObserver<? super T> actual, T defaultItem) (package private)
ReduceSeedObserver
(SingleObserver<? super R> actual, BiFunction<R, ? super T, R> reducer, R value) (package private)
SingleElementSubscriber
(SingleObserver<? super T> actual, T defaultValue) (package private)
ToListSubscriber
(SingleObserver<? super U> actual, U collection) -
Uses of SingleObserver in io.reactivex.rxjava3.internal.operators.maybe
Classes in io.reactivex.rxjava3.internal.operators.maybe that implement SingleObserverModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.maybe declared as SingleObserverModifier and TypeFieldDescription(package private) final SingleObserver
<? super Boolean> MaybeContains.ContainsMaybeObserver.downstream
(package private) final SingleObserver
<? super Long> MaybeCount.CountMaybeObserver.downstream
(package private) final SingleObserver
<? super Boolean> MaybeEqualSingle.EqualCoordinator.downstream
(package private) final SingleObserver
<? super Boolean> MaybeIsEmptySingle.IsEmptyMaybeObserver.downstream
(package private) final SingleObserver
<? super T> MaybeSwitchIfEmptySingle.SwitchIfEmptyMaybeObserver.downstream
(package private) final SingleObserver
<? super T> MaybeSwitchIfEmptySingle.SwitchIfEmptyMaybeObserver.OtherSingleObserver.downstream
(package private) final SingleObserver
<? super T> MaybeToSingle.ToSingleMaybeSubscriber.downstream
Methods in io.reactivex.rxjava3.internal.operators.maybe with parameters of type SingleObserverModifier and TypeMethodDescriptionprotected void
MaybeContains.subscribeActual
(SingleObserver<? super Boolean> observer) protected void
MaybeCount.subscribeActual
(SingleObserver<? super Long> observer) protected void
MaybeEqualSingle.subscribeActual
(SingleObserver<? super Boolean> observer) protected void
MaybeIsEmptySingle.subscribeActual
(SingleObserver<? super Boolean> observer) protected void
MaybeMaterialize.subscribeActual
(SingleObserver<? super Notification<T>> observer) protected void
MaybeSwitchIfEmptySingle.subscribeActual
(SingleObserver<? super T> observer) protected void
MaybeToSingle.subscribeActual
(SingleObserver<? super T> observer) Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type SingleObserverModifierConstructorDescription(package private)
ContainsMaybeObserver
(SingleObserver<? super Boolean> actual, Object value) (package private)
CountMaybeObserver
(SingleObserver<? super Long> downstream) (package private)
EqualCoordinator
(SingleObserver<? super Boolean> actual, BiPredicate<? super T, ? super T> isEqual) (package private)
IsEmptyMaybeObserver
(SingleObserver<? super Boolean> downstream) (package private)
OtherSingleObserver
(SingleObserver<? super T> actual, AtomicReference<Disposable> parent) (package private)
SwitchIfEmptyMaybeObserver
(SingleObserver<? super T> actual, SingleSource<? extends T> other) (package private)
ToSingleMaybeSubscriber
(SingleObserver<? super T> actual, T defaultValue) -
Uses of SingleObserver in io.reactivex.rxjava3.internal.operators.mixed
Classes in io.reactivex.rxjava3.internal.operators.mixed that implement SingleObserverModifier and TypeClassDescription(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
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.mixed declared as SingleObserverModifier and TypeFieldDescription(package private) final SingleObserver
<? super Notification<T>> MaterializeSingleObserver.downstream
Constructors in io.reactivex.rxjava3.internal.operators.mixed with parameters of type SingleObserverModifierConstructorDescriptionMaterializeSingleObserver
(SingleObserver<? super Notification<T>> downstream) -
Uses of SingleObserver in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement SingleObserverModifier and TypeClassDescription(package private) static final class
(package private) final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.observable declared as SingleObserverModifier and TypeFieldDescription(package private) final SingleObserver
<? super Boolean> ObservableAllSingle.AllObserver.downstream
(package private) final SingleObserver
<? super Boolean> ObservableAnySingle.AnyObserver.downstream
(package private) final SingleObserver
<? super U> ObservableCollectSingle.CollectObserver.downstream
(package private) final SingleObserver
<? super Long> ObservableCountSingle.CountObserver.downstream
(package private) final SingleObserver
<? super T> ObservableElementAtSingle.ElementAtObserver.downstream
(package private) final SingleObserver
<? super T> ObservableLastSingle.LastObserver.downstream
(package private) final SingleObserver
<? super R> ObservableReduceSeedSingle.ReduceSeedObserver.downstream
(package private) final SingleObserver
<? super Boolean> ObservableSequenceEqualSingle.EqualCoordinator.downstream
(package private) final SingleObserver
<? super T> ObservableSingleSingle.SingleElementObserver.downstream
(package private) final SingleObserver
<? super U> ObservableToListSingle.ToListObserver.downstream
Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type SingleObserverModifier and TypeMethodDescriptionprotected void
ObservableAllSingle.subscribeActual
(SingleObserver<? super Boolean> t) protected void
ObservableAnySingle.subscribeActual
(SingleObserver<? super Boolean> t) protected void
ObservableCollectSingle.subscribeActual
(SingleObserver<? super U> t) void
ObservableCountSingle.subscribeActual
(SingleObserver<? super Long> t) void
ObservableElementAtSingle.subscribeActual
(SingleObserver<? super T> t) protected void
ObservableLastSingle.subscribeActual
(SingleObserver<? super T> observer) protected void
ObservableReduceSeedSingle.subscribeActual
(SingleObserver<? super R> observer) protected void
ObservableReduceWithSingle.subscribeActual
(SingleObserver<? super R> observer) void
ObservableSequenceEqualSingle.subscribeActual
(SingleObserver<? super Boolean> observer) void
ObservableSingleSingle.subscribeActual
(SingleObserver<? super T> t) void
ObservableToListSingle.subscribeActual
(SingleObserver<? super U> t) Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type SingleObserverModifierConstructorDescription(package private)
AllObserver
(SingleObserver<? super Boolean> actual, Predicate<? super T> predicate) (package private)
AnyObserver
(SingleObserver<? super Boolean> actual, Predicate<? super T> predicate) (package private)
CollectObserver
(SingleObserver<? super U> actual, U u, BiConsumer<? super U, ? super T> collector) (package private)
CountObserver
(SingleObserver<? super Long> downstream) (package private)
ElementAtObserver
(SingleObserver<? super T> actual, long index, T defaultValue) (package private)
EqualCoordinator
(SingleObserver<? super Boolean> actual, int bufferSize, ObservableSource<? extends T> first, ObservableSource<? extends T> second, BiPredicate<? super T, ? super T> comparer) (package private)
LastObserver
(SingleObserver<? super T> actual, T defaultItem) (package private)
ReduceSeedObserver
(SingleObserver<? super R> actual, BiFunction<R, ? super T, R> reducer, R value) (package private)
SingleElementObserver
(SingleObserver<? super T> actual, T defaultValue) (package private)
ToListObserver
(SingleObserver<? super U> actual, U collection) -
Uses of SingleObserver in io.reactivex.rxjava3.internal.operators.single
Classes in io.reactivex.rxjava3.internal.operators.single that implement SingleObserverModifier and TypeClassDescription(package private) static final class
final class
SingleCache<T>
(package private) 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) static final class
(package private) final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) final class
(package private) static 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) 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) 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) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.single declared as SingleObserverModifier and TypeFieldDescription(package private) final SingleObserver
<? super T> SingleAmb.AmbSingleObserver.downstream
(package private) final SingleObserver
<? super T> SingleCache.CacheDisposable.downstream
private final SingleObserver
<? super Boolean> SingleContains.ContainsSingleObserver.downstream
(package private) final SingleObserver
<? super T> SingleCreate.Emitter.downstream
(package private) final SingleObserver
<? super T> SingleDelay.Delay.downstream
(package private) final SingleObserver
<? super T> SingleDelayWithCompletable.OtherObserver.downstream
(package private) final SingleObserver
<? super T> SingleDelayWithObservable.OtherSubscriber.downstream
(package private) final SingleObserver
<? super T> SingleDelayWithPublisher.OtherSubscriber.downstream
(package private) final SingleObserver
<? super T> SingleDelayWithSingle.OtherObserver.downstream
(package private) SingleObserver
<? super T> SingleDetach.DetachSingleObserver.downstream
(package private) final SingleObserver
<? super T> SingleDoAfterSuccess.DoAfterObserver.downstream
(package private) final SingleObserver
<? super T> SingleDoAfterTerminate.DoAfterTerminateObserver.downstream
(package private) final SingleObserver
<? super T> SingleDoFinally.DoFinallyObserver.downstream
(package private) final SingleObserver
<? super T> SingleDoOnDispose.DoOnDisposeObserver.downstream
private final SingleObserver
<? super T> SingleDoOnError.DoOnError.downstream
private final SingleObserver
<? super T> SingleDoOnEvent.DoOnEvent.downstream
(package private) final SingleObserver
<? super T> SingleDoOnLifecycle.SingleLifecycleObserver.downstream
(package private) final SingleObserver
<? super T> SingleDoOnSubscribe.DoOnSubscribeSingleObserver.downstream
(package private) final SingleObserver
<? super T> SingleDoOnSuccess.DoOnSuccess.downstream
(package private) final SingleObserver
<? super T> SingleDoOnTerminate.DoOnTerminate.downstream
(package private) final SingleObserver
<? super Boolean> SingleEquals.InnerObserver.downstream
(package private) final SingleObserver
<? super R> SingleFlatMap.SingleFlatMapCallback.downstream
(package private) final SingleObserver
<? super R> SingleFlatMap.SingleFlatMapCallback.FlatMapSingleObserver.downstream
(package private) final SingleObserver
<? super R> SingleFlatMapBiSelector.FlatMapBiMainObserver.InnerObserver.downstream
(package private) final SingleObserver
<? super R> SingleFlatMapNotification.FlatMapSingleObserver.downstream
(package private) final SingleObserver
<? super T> SingleFromPublisher.ToSingleObserver.downstream
(package private) final SingleObserver
<? super T> SingleHide.HideSingleObserver.downstream
(package private) final SingleObserver
<? super T> SingleObserveOn.ObserveOnSingleObserver.downstream
(package private) final SingleObserver
<? super T> SingleResumeNext.ResumeMainSingleObserver.downstream
(package private) final SingleObserver
<? super T> SingleSubscribeOn.SubscribeOnObserver.downstream
(package private) final SingleObserver
<? super T> SingleTakeUntil.TakeUntilMainObserver.downstream
(package private) final SingleObserver
<? super Timed<T>> SingleTimeInterval.TimeIntervalSingleObserver.downstream
(package private) final SingleObserver
<? super T> SingleTimeout.TimeoutMainObserver.downstream
(package private) final SingleObserver
<? super T> SingleTimeout.TimeoutMainObserver.TimeoutFallbackObserver.downstream
(package private) final SingleObserver
<? super Long> SingleTimer.TimerDisposable.downstream
(package private) final SingleObserver
<? super T> SingleUnsubscribeOn.UnsubscribeOnSingleObserver.downstream
(package private) final SingleObserver
<? super T> SingleUsing.UsingSingleObserver.downstream
(package private) final SingleObserver
<? super R> SingleZipArray.ZipCoordinator.downstream
private final SingleObserver
<? super T> SingleOnErrorReturn.OnErrorReturn.observer
(package private) final SingleObserver
<? super R> SingleMap.MapSingleObserver.t
Methods in io.reactivex.rxjava3.internal.operators.single that return SingleObserverModifier and TypeMethodDescriptionstatic <T> SingleObserver
<T> Creates aSingleObserver
wrapper around aObserver
.Methods in io.reactivex.rxjava3.internal.operators.single with parameters of type SingleObserverModifier and TypeMethodDescriptionprotected void
SingleAmb.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleCache.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleContains.subscribeActual
(SingleObserver<? super Boolean> observer) protected void
SingleCreate.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDefer.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDelay.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDelayWithCompletable.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDelayWithObservable.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDelayWithPublisher.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDelayWithSingle.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDetach.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDoAfterSuccess.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDoAfterTerminate.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDoFinally.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDoOnDispose.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDoOnError.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDoOnEvent.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDoOnLifecycle.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDoOnSubscribe.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDoOnSuccess.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleDoOnTerminate.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleEquals.subscribeActual
(SingleObserver<? super Boolean> observer) protected void
SingleError.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleFlatMap.subscribeActual
(SingleObserver<? super R> downstream) protected void
SingleFlatMapBiSelector.subscribeActual
(SingleObserver<? super R> observer) protected void
SingleFlatMapNotification.subscribeActual
(SingleObserver<? super R> observer) protected void
SingleFromCallable.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleFromPublisher.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleFromSupplier.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleFromUnsafeSource.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleHide.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleJust.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleLift.subscribeActual
(SingleObserver<? super R> observer) protected void
SingleMap.subscribeActual
(SingleObserver<? super R> t) protected void
SingleMaterialize.subscribeActual
(SingleObserver<? super Notification<T>> observer) protected void
SingleNever.subscribeActual
(SingleObserver<? super Object> observer) protected void
SingleObserveOn.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleOnErrorReturn.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleResumeNext.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleSubscribeOn.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleTakeUntil.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleTimeInterval.subscribeActual
(@NonNull SingleObserver<? super @NonNull Timed<T>> observer) protected void
SingleTimeout.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleTimer.subscribeActual
(SingleObserver<? super Long> observer) protected void
SingleUnsubscribeOn.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleUsing.subscribeActual
(SingleObserver<? super T> observer) protected void
SingleZipArray.subscribeActual
(SingleObserver<? super R> observer) protected void
SingleZipIterable.subscribeActual
(SingleObserver<? super R> observer) Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type SingleObserverModifierConstructorDescription(package private)
AmbSingleObserver
(SingleObserver<? super T> observer, CompositeDisposable set, AtomicBoolean winner) (package private)
CacheDisposable
(SingleObserver<? super T> actual, SingleCache<T> parent) (package private)
ContainsSingleObserver
(SingleObserver<? super Boolean> observer) (package private)
Delay
(SequentialDisposable sd, SingleObserver<? super T> observer) (package private)
DetachSingleObserver
(SingleObserver<? super T> downstream) (package private)
DoAfterObserver
(SingleObserver<? super T> actual, Consumer<? super T> onAfterSuccess) (package private)
DoAfterTerminateObserver
(SingleObserver<? super T> actual, Action onAfterTerminate) (package private)
DoFinallyObserver
(SingleObserver<? super T> actual, Action onFinally) (package private)
DoOnDisposeObserver
(SingleObserver<? super T> actual, Action onDispose) (package private)
DoOnError
(SingleObserver<? super T> observer) (package private)
DoOnEvent
(SingleObserver<? super T> observer) (package private)
DoOnSubscribeSingleObserver
(SingleObserver<? super T> actual, Consumer<? super Disposable> onSubscribe) (package private)
DoOnSuccess
(SingleObserver<? super T> observer) (package private)
DoOnTerminate
(SingleObserver<? super T> observer) (package private)
Emitter
(SingleObserver<? super T> downstream) (package private)
FlatMapBiMainObserver
(SingleObserver<? super R> actual, Function<? super T, ? extends SingleSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> resultSelector) (package private)
FlatMapSingleObserver
(AtomicReference<Disposable> parent, SingleObserver<? super R> downstream) (package private)
FlatMapSingleObserver
(SingleObserver<? super R> actual, Function<? super T, ? extends SingleSource<? extends R>> onSuccessMapper, Function<? super Throwable, ? extends SingleSource<? extends R>> onErrorMapper) (package private)
HideSingleObserver
(SingleObserver<? super T> downstream) (package private)
InnerObserver
(int index, CompositeDisposable set, Object[] values, SingleObserver<? super Boolean> observer, AtomicInteger count) (package private)
InnerObserver
(SingleObserver<? super R> actual, BiFunction<? super T, ? super U, ? extends R> resultSelector) (package private)
MapSingleObserver
(SingleObserver<? super R> t, Function<? super T, ? extends R> mapper) (package private)
ObserveOnSingleObserver
(SingleObserver<? super T> actual, Scheduler scheduler) (package private)
OnErrorReturn
(SingleObserver<? super T> observer) (package private)
OtherObserver
(SingleObserver<? super T> actual, SingleSource<T> source) (package private)
OtherObserver
(SingleObserver<? super T> actual, SingleSource<T> source) (package private)
OtherSubscriber
(SingleObserver<? super T> actual, SingleSource<T> source) (package private)
OtherSubscriber
(SingleObserver<? super T> actual, SingleSource<T> source) (package private)
ResumeMainSingleObserver
(SingleObserver<? super T> actual, Function<? super Throwable, ? extends SingleSource<? extends T>> nextFunction) (package private)
SingleFlatMapCallback
(SingleObserver<? super R> actual, Function<? super T, ? extends SingleSource<? extends R>> mapper) (package private)
SingleLifecycleObserver
(SingleObserver<? super T> downstream, Consumer<? super Disposable> onSubscribe, Action onDispose) (package private)
SubscribeOnObserver
(SingleObserver<? super T> actual, SingleSource<? extends T> source) (package private)
TakeUntilMainObserver
(SingleObserver<? super T> downstream) (package private)
TimeIntervalSingleObserver
(SingleObserver<? super Timed<T>> downstream, TimeUnit unit, Scheduler scheduler, boolean start) (package private)
TimeoutFallbackObserver
(SingleObserver<? super T> downstream) (package private)
TimeoutMainObserver
(SingleObserver<? super T> actual, SingleSource<? extends T> other, long timeout, TimeUnit unit) (package private)
TimerDisposable
(SingleObserver<? super Long> downstream) (package private)
ToSingleObserver
(SingleObserver<? super T> downstream) (package private)
UnsubscribeOnSingleObserver
(SingleObserver<? super T> actual, Scheduler scheduler) (package private)
UsingSingleObserver
(SingleObserver<? super T> actual, U resource, boolean eager, Consumer<? super U> disposer) (package private)
ZipCoordinator
(SingleObserver<? super R> observer, int n, Function<? super Object[], ? extends R> zipper) -
Uses of SingleObserver in io.reactivex.rxjava3.internal.util
Classes in io.reactivex.rxjava3.internal.util that implement SingleObserverModifier and TypeClassDescriptionenum
Singleton implementing many interfaces as empty.Methods in io.reactivex.rxjava3.internal.util with parameters of type SingleObserverModifier and TypeMethodDescriptionvoid
AtomicThrowable.tryTerminateConsumer
(SingleObserver<?> 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 SingleObserver in io.reactivex.rxjava3.observers
Classes in io.reactivex.rxjava3.observers that implement SingleObserverModifier and TypeClassDescriptionclass
An abstractSingleObserver
that allows asynchronous cancellation by implementingDisposable
.class
An abstractSingleObserver
that allows asynchronous cancellation of its subscription and the 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 SingleObserver in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins with type parameters of type SingleObserverModifier and TypeFieldDescription(package private) static @Nullable BiFunction
<? super Single, @NonNull ? super SingleObserver, @NonNull ? extends SingleObserver> RxJavaPlugins.onSingleSubscribe
(package private) static @Nullable BiFunction
<? super Single, @NonNull ? super SingleObserver, @NonNull ? extends SingleObserver> RxJavaPlugins.onSingleSubscribe
Methods in io.reactivex.rxjava3.plugins that return SingleObserverModifier and TypeMethodDescriptionstatic <@NonNull T>
@NonNull SingleObserver<? super T> RxJavaPlugins.onSubscribe
(@NonNull Single<@NonNull T> source, @NonNull SingleObserver<? super @NonNull T> observer) Calls the associated hook function.Methods in io.reactivex.rxjava3.plugins that return types with arguments of type SingleObserverModifier and TypeMethodDescriptionstatic @Nullable BiFunction
<? super Single, @NonNull ? super SingleObserver, @NonNull ? extends SingleObserver> RxJavaPlugins.getOnSingleSubscribe()
Returns the current hook function.static @Nullable BiFunction
<? super Single, @NonNull ? super SingleObserver, @NonNull ? extends SingleObserver> RxJavaPlugins.getOnSingleSubscribe()
Returns the current hook function.Methods in io.reactivex.rxjava3.plugins with parameters of type SingleObserverModifier and TypeMethodDescriptionstatic <@NonNull T>
@NonNull SingleObserver<? super T> RxJavaPlugins.onSubscribe
(@NonNull Single<@NonNull T> source, @NonNull SingleObserver<? super @NonNull T> observer) Calls the associated hook function.Method parameters in io.reactivex.rxjava3.plugins with type arguments of type SingleObserverModifier and TypeMethodDescriptionstatic void
RxJavaPlugins.setOnSingleSubscribe
(@Nullable BiFunction<? super Single, @NonNull ? super SingleObserver, @NonNull ? extends SingleObserver> onSingleSubscribe) Sets the specific hook function.static void
RxJavaPlugins.setOnSingleSubscribe
(@Nullable BiFunction<? super Single, @NonNull ? super SingleObserver, @NonNull ? extends SingleObserver> onSingleSubscribe) Sets the specific hook function. -
Uses of SingleObserver in io.reactivex.rxjava3.subjects
Classes in io.reactivex.rxjava3.subjects that implement SingleObserverModifier and TypeClassDescriptionfinal class
Represents a hot Single-like source and consumer of events similar to Subjects.Fields in io.reactivex.rxjava3.subjects declared as SingleObserverModifier and TypeFieldDescription(package private) final SingleObserver
<? super T> SingleSubject.SingleDisposable.downstream
Methods in io.reactivex.rxjava3.subjects with parameters of type SingleObserverModifier and TypeMethodDescriptionprotected void
SingleSubject.subscribeActual
(@NonNull SingleObserver<? super T> observer) Constructors in io.reactivex.rxjava3.subjects with parameters of type SingleObserverModifierConstructorDescription(package private)
SingleDisposable
(SingleObserver<? super T> actual, SingleSubject<T> parent)