Uses of Interface
io.reactivex.rxjava3.core.SingleObserver

Packages that use SingleObserver

Package	Description
io.reactivex.rxjava3.core	Base reactive classes: Flowable, Observable, Single, Maybe and Completable; base reactive consumers; other common base interfaces.
io.reactivex.rxjava3.internal.disposables
io.reactivex.rxjava3.internal.jdk8
io.reactivex.rxjava3.internal.observers
io.reactivex.rxjava3.internal.operators.completable
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.maybe
io.reactivex.rxjava3.internal.operators.mixed
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.operators.single
io.reactivex.rxjava3.internal.util
io.reactivex.rxjava3.observers	Default wrappers and implementations for observer-based consumer classes and interfaces, including disposable and resource-tracking variants and the TestObserver that allows unit testing Observable-, Single-, Maybe- and Completable-based flows.
io.reactivex.rxjava3.plugins	Contains the central plugin handler RxJavaPlugins class to hook into the lifecycle of the base reactive types and schedulers.
io.reactivex.rxjava3.subjects	Classes representing so-called hot sources, aka subjects, that implement a base reactive class and the respective consumer type at once to allow forms of multicasting events to multiple consumers as well as consuming another base reactive type of their kind.

Uses of SingleObserver in io.reactivex.rxjava3.core

Methods in io.reactivex.rxjava3.core with type parameters of type SingleObserver

Modifier and Type	Method	Description
final <@NonNull E extends SingleObserver<? super @NonNull T>> E	Single.subscribeWith(@NonNull E observer)	Subscribes a given SingleObserver (subclass) to this Single and returns the given SingleObserver as is.

Methods in io.reactivex.rxjava3.core that return SingleObserver

Modifier and Type	Method	Description
@NonNull SingleObserver<? super Upstream>	SingleOperator.apply(@NonNull SingleObserver<? super @NonNull Downstream> observer)	Applies a function to the child SingleObserver and returns a new parent SingleObserver.

Methods in io.reactivex.rxjava3.core with parameters of type SingleObserver

Modifier and Type	Method	Description
@NonNull SingleObserver<? super Upstream>	SingleOperator.apply(@NonNull SingleObserver<? super @NonNull Downstream> observer)	Applies a function to the child SingleObserver and returns a new parent SingleObserver.
final void	Single.blockingSubscribe(@NonNull SingleObserver<? super @NonNull T> observer)	Subscribes to the current Single and calls the appropriate SingleObserver method on the current thread.
final void	Single.safeSubscribe(@NonNull SingleObserver<? super @NonNull T> observer)	Wraps the given SingleObserver, catches any RuntimeExceptions thrown by its SingleObserver.onSubscribe(Disposable), SingleObserver.onSuccess(Object) or SingleObserver.onError(Throwable) methods* and routes those to the global error handler via RxJavaPlugins.onError(Throwable).
final void	Single.subscribe(@NonNull SingleObserver<? super @NonNull T> observer)
void	SingleSource.subscribe(@NonNull SingleObserver<? super @NonNull T> observer)	Subscribes the given SingleObserver to this SingleSource instance.
protected abstract void	Single.subscribeActual(@NonNull SingleObserver<? super @NonNull T> observer)	Implement this method in subclasses to handle the incoming SingleObservers.

Uses of SingleObserver in io.reactivex.rxjava3.internal.disposables

Methods in io.reactivex.rxjava3.internal.disposables with parameters of type SingleObserver

Modifier and Type	Method	Description
static 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 SingleObserver

Modifier and Type	Class	Description
final class	CompletionStageConsumer<T>	Class that extends CompletableFuture and converts multiple types of reactive consumers and their signals into completion signals.
(package private) static final class	MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver<T,R>
(package private) static final class	MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver<T,R>
(package private) static final class	SingleMapOptional.MapOptionalSingleObserver<T,R>

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

Modifier and Type	Field	Description
(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 SingleObserver

Modifier and Type	Method	Description
protected 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 SingleObserver

Modifier	Constructor	Description
(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 SingleObserver

Modifier and Type	Class	Description
final class	BiConsumerSingleObserver<T>
final class	BlockingDisposableMultiObserver<T>	Blocks until the upstream terminates and dispatches the outcome to the actual observer.
final class	BlockingMultiObserver<T>	A combined Observer that awaits the success or error signal via a CountDownLatch.
final class	ConsumerSingleObserver<T>
final class	DisposableAutoReleaseMultiObserver<T>	Wraps lambda callbacks and when the upstream terminates or this (Single | Maybe | Completable) observer gets disposed, removes itself from a CompositeDisposable.
final class	FutureMultiObserver<T>	An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.
final class	ResumeSingleObserver<T>	A SingleObserver implementation used for subscribing to the actual SingleSource and replace the current Disposable in a parent AtomicReference.
final class	SafeSingleObserver<T>	Wraps another SingleObserver and catches exceptions thrown by its onSubscribe, onSuccess or onError methods despite the protocol forbids it.

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

Modifier and Type	Field	Description
(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 SingleObserver

Modifier and Type	Method	Description
void	BlockingDisposableMultiObserver.blockingConsume(SingleObserver<? super T> observer)

Constructors in io.reactivex.rxjava3.internal.observers with parameters of type SingleObserver

Modifier	Constructor	Description
	ResumeSingleObserver(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 SingleObserver

Modifier and Type	Class	Description
(package private) static final class	CompletableFromSingle.CompletableFromSingleObserver<T>

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

Modifier and Type	Field	Description
private final SingleObserver<? super T>	CompletableToSingle.ToSingle.observer

Methods in io.reactivex.rxjava3.internal.operators.completable with parameters of type SingleObserver

Modifier and Type	Method	Description
protected 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

Modifier	Constructor	Description
(package private)	ToSingle(SingleObserver<? super T> observer)

Uses of SingleObserver in io.reactivex.rxjava3.internal.operators.flowable

Classes in io.reactivex.rxjava3.internal.operators.flowable that implement SingleObserver

Modifier and Type	Class	Description
(package private) static final class	FlowableConcatWithSingle.ConcatWithSubscriber<T>
(package private) final class	FlowableFlatMapSingle.FlatMapSingleSubscriber.InnerObserver
(package private) static final class	FlowableMergeWithSingle.MergeWithObserver.OtherObserver<T>

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

Modifier and Type	Field	Description
(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 SingleObserver

Modifier and Type	Method	Description
protected 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 SingleObserver

Modifier	Constructor	Description
(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 SingleObserver

Modifier and Type	Class	Description
(package private) static final class	MaybeFilterSingle.FilterMaybeObserver<T>
(package private) static final class	MaybeFlatMapSingle.FlatMapSingleObserver<R>
(package private) static final class	MaybeFromSingle.FromSingleObserver<T>
static final class	MaybeOnErrorComplete.OnErrorCompleteMultiObserver<T>
(package private) static final class	MaybeSwitchIfEmptySingle.SwitchIfEmptyMaybeObserver.OtherSingleObserver<T>

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

Modifier and Type	Field	Description
(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 SingleObserver

Modifier and Type	Method	Description
protected 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 SingleObserver

Modifier	Constructor	Description
(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 SingleObserver

Modifier and Type	Class	Description
(package private) static final class	FlowableConcatMapSingle.ConcatMapSingleSubscriber.ConcatMapSingleObserver<R>
(package private) static final class	FlowableSwitchMapSingle.SwitchMapSingleSubscriber.SwitchMapSingleObserver<R>
final class	MaterializeSingleObserver<T>	A consumer that implements the consumer types of Maybe, Single and Completable and turns their signals into Notifications for a SingleObserver.
(package private) static final class	ObservableConcatMapSingle.ConcatMapSingleMainObserver.ConcatMapSingleObserver<R>
(package private) static final class	ObservableSwitchMapSingle.SwitchMapSingleMainObserver.SwitchMapSingleObserver<R>
(package private) static final class	SingleFlatMapObservable.FlatMapObserver<T,R>

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

Modifier and Type	Field	Description
(package private) final SingleObserver<? super Notification<T>>	MaterializeSingleObserver.downstream

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

Modifier	Constructor	Description
	MaterializeSingleObserver(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 SingleObserver

Modifier and Type	Class	Description
(package private) static final class	ObservableConcatWithSingle.ConcatWithObserver<T>
(package private) final class	ObservableFlatMapSingle.FlatMapSingleObserver.InnerObserver
(package private) static final class	ObservableMergeWithSingle.MergeWithObserver.OtherObserver<T>

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

Modifier and Type	Field	Description
(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 SingleObserver

Modifier and Type	Method	Description
protected 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 SingleObserver

Modifier	Constructor	Description
(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 SingleObserver

Modifier and Type	Class	Description
(package private) static final class	SingleAmb.AmbSingleObserver<T>
final class	SingleCache<T>
(package private) final class	SingleContains.ContainsSingleObserver
(package private) final class	SingleDelay.Delay
(package private) static final class	SingleDelayWithSingle.OtherObserver<T,U>
(package private) static final class	SingleDematerialize.DematerializeObserver<T,R>
(package private) static final class	SingleDetach.DetachSingleObserver<T>
(package private) static final class	SingleDoAfterSuccess.DoAfterObserver<T>
(package private) static final class	SingleDoAfterTerminate.DoAfterTerminateObserver<T>
(package private) static final class	SingleDoFinally.DoFinallyObserver<T>
(package private) static final class	SingleDoOnDispose.DoOnDisposeObserver<T>
(package private) final class	SingleDoOnError.DoOnError
(package private) final class	SingleDoOnEvent.DoOnEvent
(package private) static final class	SingleDoOnLifecycle.SingleLifecycleObserver<T>
(package private) static final class	SingleDoOnSubscribe.DoOnSubscribeSingleObserver<T>
(package private) final class	SingleDoOnSuccess.DoOnSuccess
(package private) final class	SingleDoOnTerminate.DoOnTerminate
(package private) static class	SingleEquals.InnerObserver<T>
(package private) static final class	SingleFlatMap.SingleFlatMapCallback<T,R>
(package private) static final class	SingleFlatMap.SingleFlatMapCallback.FlatMapSingleObserver<R>
(package private) static final class	SingleFlatMapBiSelector.FlatMapBiMainObserver<T,U,R>
(package private) static final class	SingleFlatMapBiSelector.FlatMapBiMainObserver.InnerObserver<T,U,R>
(package private) static final class	SingleFlatMapCompletable.FlatMapCompletableObserver<T>
(package private) static final class	SingleFlatMapIterableFlowable.FlatMapIterableObserver<T,R>
(package private) static final class	SingleFlatMapIterableObservable.FlatMapIterableObserver<T,R>
(package private) static final class	SingleFlatMapMaybe.FlatMapSingleObserver<T,R>
(package private) static final class	SingleFlatMapNotification.FlatMapSingleObserver<T,R>
(package private) final class	SingleFlatMapNotification.FlatMapSingleObserver.InnerObserver
(package private) static final class	SingleFlatMapPublisher.SingleFlatMapPublisherObserver<S,T>
(package private) static final class	SingleHide.HideSingleObserver<T>
(package private) static final class	SingleMap.MapSingleObserver<T,R>
(package private) static final class	SingleObserveOn.ObserveOnSingleObserver<T>
(package private) final class	SingleOnErrorReturn.OnErrorReturn
(package private) static final class	SingleResumeNext.ResumeMainSingleObserver<T>
(package private) static final class	SingleSubscribeOn.SubscribeOnObserver<T>
(package private) static final class	SingleTakeUntil.TakeUntilMainObserver<T>
(package private) static final class	SingleTimeInterval.TimeIntervalSingleObserver<T>
(package private) static final class	SingleTimeout.TimeoutMainObserver<T>
(package private) static final class	SingleTimeout.TimeoutMainObserver.TimeoutFallbackObserver<T>
(package private) static final class	SingleToFlowable.SingleToFlowableObserver<T>
(package private) static final class	SingleToObservable.SingleToObservableObserver<T>
(package private) static final class	SingleUnsubscribeOn.UnsubscribeOnSingleObserver<T>
(package private) static final class	SingleUsing.UsingSingleObserver<T,U>
(package private) static final class	SingleZipArray.ZipSingleObserver<T>

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

Modifier and Type	Field	Description
(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 SingleObserver

Modifier and Type	Method	Description
static <T> SingleObserver<T>	SingleToObservable.create(Observer<? super T> downstream)	Creates a SingleObserver wrapper around a Observer.

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

Modifier and Type	Method	Description
protected 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 SingleObserver

Modifier	Constructor	Description
(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 SingleObserver

Modifier and Type	Class	Description
enum	EmptyComponent	Singleton implementing many interfaces as empty.

Methods in io.reactivex.rxjava3.internal.util with parameters of type SingleObserver

Modifier and Type	Method	Description
void	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 SingleObserver

Modifier and Type	Class	Description
class	DisposableSingleObserver<T>	An abstract SingleObserver that allows asynchronous cancellation by implementing Disposable.
class	ResourceSingleObserver<T>	An abstract SingleObserver that allows asynchronous cancellation of its subscription and the associated resources.
class	TestObserver<T>	An Observer, MaybeObserver, SingleObserver and CompletableObserver composite that can record events from Observables, Maybes, Singles and Completables and allows making assertions about them.

Uses of SingleObserver in io.reactivex.rxjava3.plugins

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

Modifier and Type	Field	Description
(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 SingleObserver

Modifier and Type	Method	Description
static <@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 SingleObserver

Modifier and Type	Method	Description
static @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 SingleObserver

Modifier and Type	Method	Description
static <@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 SingleObserver

Modifier and Type	Method	Description
static 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 SingleObserver

Modifier and Type	Class	Description
final class	SingleSubject<T>	Represents a hot Single-like source and consumer of events similar to Subjects.

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

Modifier and Type	Field	Description
(package private) final SingleObserver<? super T>	SingleSubject.SingleDisposable.downstream

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

Modifier and Type	Method	Description
protected void	SingleSubject.subscribeActual(@NonNull SingleObserver<? super T> observer)

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

Modifier	Constructor	Description
(package private)	SingleDisposable(SingleObserver<? super T> actual, SingleSubject<T> parent)