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.

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)

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.

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

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)

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

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)

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
static final class	MaybeOnErrorComplete.OnErrorCompleteMultiObserver<T>

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)

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
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.

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

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)

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
final class	SingleCache<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)

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

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.

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)