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

Packages that use Observer

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 Observer in io.reactivex.rxjava3.core

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

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

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

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

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

Modifier and Type	Method	Description
@NonNull Observer<? super Upstream>	ObservableOperator.apply(@NonNull Observer<? super @NonNull Downstream> observer)	Applies a function to the child Observer and returns a new parent Observer.
final void	Observable.blockingSubscribe(@NonNull Observer<? super @NonNull T> observer)	Subscribes to the source and calls the Observer methods on the current thread.
final @NonNull Observable<T>	Observable.doOnEach(@NonNull Observer<? super @NonNull T> observer)	Returns an Observable that forwards the items and terminal events of the current Observable to its Observers and to the given shared Observer instance.
final void	Observable.safeSubscribe(@NonNull Observer<? super @NonNull T> observer)	Subscribes to the current Observable and wraps the given Observer into a SafeObserver (if not already a SafeObserver) that deals with exceptions thrown by a misbehaving Observer (that doesn't follow the Reactive Streams specification).
final void	Observable.subscribe(@NonNull Observer<? super @NonNull T> observer)
void	ObservableSource.subscribe(@NonNull Observer<? super @NonNull T> observer)	Subscribes the given Observer to this ObservableSource instance.
protected abstract void	Observable.subscribeActual(@NonNull Observer<? super @NonNull T> observer)	Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic and handles the incoming Observers.

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

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

Modifier and Type	Method	Description
static void	EmptyDisposable.complete(Observer<?> observer)
static void	EmptyDisposable.error(Throwable e, Observer<?> observer)

Uses of Observer in io.reactivex.rxjava3.internal.jdk8

Classes in io.reactivex.rxjava3.internal.jdk8 that implement Observer

Modifier and Type	Class	Description
(package private) static final class	ObservableCollectWithCollector.CollectorObserver<T,A,R>
(package private) static final class	ObservableCollectWithCollectorSingle.CollectorSingleObserver<T,A,R>
final class	ObservableFirstStageObserver<T>	Signals the first element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signals NoSuchElementException.
(package private) static final class	ObservableFlatMapStream.FlatMapStreamObserver<T,R>
final class	ObservableLastStageObserver<T>	Signals the last element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signals NoSuchElementException.
(package private) static final class	ObservableMapOptional.MapOptionalObserver<T,R>
final class	ObservableSingleStageObserver<T>	Signals the only element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signals IllegalArgumentException if the upstream has more than one item.
(package private) class	ObservableStageObserver<T>	Base class that extends CompletableFuture and provides basic infrastructure to notify watchers upon upstream signals.

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

Modifier and Type	Field	Description
(package private) final Observer<? super R>	MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver.downstream
(package private) final Observer<? super R>	ObservableFlatMapStream.FlatMapStreamObserver.downstream
(package private) final Observer<? super T>	ObservableFromStream.StreamDisposable.downstream

Methods in io.reactivex.rxjava3.internal.jdk8 with parameters of type Observer

Modifier and Type	Method	Description
protected void	MaybeFlattenStreamAsObservable.subscribeActual(@NonNull Observer<? super R> s)
protected void	ObservableCollectWithCollector.subscribeActual(@NonNull Observer<? super R> observer)
protected void	ObservableFlatMapStream.subscribeActual(Observer<? super R> observer)
protected void	ObservableFromCompletionStage.subscribeActual(Observer<? super T> observer)
protected void	ObservableFromStream.subscribeActual(Observer<? super T> observer)
protected void	ObservableMapOptional.subscribeActual(Observer<? super R> observer)
protected void	SingleFlattenStreamAsObservable.subscribeActual(@NonNull Observer<? super R> s)
static <T> void	ObservableFromStream.subscribeStream(Observer<? super T> observer, Stream<T> stream)	Subscribes to the Stream.

Constructors in io.reactivex.rxjava3.internal.jdk8 with parameters of type Observer

Modifier	Constructor	Description
(package private)	CollectorObserver(Observer<? super R> downstream, A container, BiConsumer<A,T> accumulator, Function<A,R> finisher)
(package private)	CompletionStageHandler(Observer<? super T> downstream, ObservableFromCompletionStage.BiConsumerAtomicReference<T> whenReference)
(package private)	FlatMapStreamObserver(Observer<? super R> downstream, Function<? super T, ? extends Stream<? extends R>> mapper)
(package private)	FlattenStreamMultiObserver(Observer<? super R> downstream, Function<? super T, ? extends Stream<? extends R>> mapper)
(package private)	MapOptionalObserver(Observer<? super R> downstream, Function<? super T, Optional<? extends R>> mapper)
(package private)	StreamDisposable(Observer<? super T> downstream, Iterator<T> iterator, AutoCloseable closeable)

Uses of Observer in io.reactivex.rxjava3.internal.observers

Classes in io.reactivex.rxjava3.internal.observers that implement Observer

Modifier and Type	Class	Description
class	BasicFuseableObserver<T,R>	Base class for a fuseable intermediate observer.
class	BlockingBaseObserver<T>
final class	BlockingFirstObserver<T>	Blocks until the upstream signals its first value or completes.
final class	BlockingLastObserver<T>	Blocks until the upstream signals its last value or completes.
final class	BlockingObserver<T>
class	DeferredScalarObserver<T,R>	A fuseable Observer that can generate 0 or 1 resulting value.
final class	DisposableAutoReleaseObserver<T>	Wraps lambda callbacks and when the upstream terminates or this observer gets disposed, removes itself from a CompositeDisposable.
final class	DisposableLambdaObserver<T>
final class	ForEachWhileObserver<T>
final class	FutureObserver<T>	An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.
final class	InnerQueuedObserver<T>	Subscriber that can fuse with the upstream and calls a support interface whenever an event is available.
final class	LambdaObserver<T>
class	QueueDrainObserver<T,U,V>	Abstract base class for subscribers that hold another subscriber, a queue and requires queue-drain behavior.

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

Modifier and Type	Field	Description
protected final Observer<? super R>	BasicFuseableObserver.downstream	The downstream subscriber.
protected final Observer<? super T>	DeferredScalarDisposable.downstream	The target of the events.
(package private) final Observer<? super T>	DisposableLambdaObserver.downstream
protected final Observer<? super V>	QueueDrainObserver.downstream

Methods in io.reactivex.rxjava3.internal.observers with parameters of type Observer

Modifier and Type	Method	Description
void	QueueDrainObserver.accept(Observer<? super V> a, U v)

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

Modifier	Constructor	Description
	BasicFuseableObserver(Observer<? super R> downstream)	Construct a BasicFuseableObserver by wrapping the given subscriber.
	DeferredScalarDisposable(Observer<? super T> downstream)	Constructs a DeferredScalarDisposable by wrapping the Observer.
	DeferredScalarObserver(Observer<? super R> downstream)	Creates a DeferredScalarObserver instance and wraps a downstream Observer.
	DisposableLambdaObserver(Observer<? super T> actual, Consumer<? super Disposable> onSubscribe, Action onDispose)
	QueueDrainObserver(Observer<? super V> actual, SimplePlainQueue<U> queue)

Uses of Observer in io.reactivex.rxjava3.internal.operators.completable

Classes in io.reactivex.rxjava3.internal.operators.completable that implement Observer

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

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

Modifier and Type	Method	Description
protected void	CompletableToObservable.subscribeActual(Observer<? super T> observer)

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

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

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

Uses of Observer in io.reactivex.rxjava3.internal.operators.maybe

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

Modifier and Type	Field	Description
(package private) final Observer<? super R>	MaybeFlatMapIterableObservable.FlatMapIterableObserver.downstream

Methods in io.reactivex.rxjava3.internal.operators.maybe with parameters of type Observer

Modifier and Type	Method	Description
static <T> MaybeObserver<T>	MaybeToObservable.create(Observer<? super T> downstream)	Creates a MaybeObserver wrapper around a Observer.
protected void	MaybeFlatMapIterableObservable.subscribeActual(Observer<? super R> observer)
protected void	MaybeToObservable.subscribeActual(Observer<? super T> observer)

Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type Observer

Modifier	Constructor	Description
(package private)	FlatMapIterableObserver(Observer<? super R> actual, Function<? super T, ? extends Iterable<? extends R>> mapper)
(package private)	MaybeToObservableObserver(Observer<? super T> downstream)

Uses of Observer in io.reactivex.rxjava3.internal.operators.mixed

Classes in io.reactivex.rxjava3.internal.operators.mixed that implement Observer

Modifier and Type	Class	Description
(package private) static final class	CompletableAndThenObservable.AndThenObservableObserver<R>
class	ConcatMapXMainObserver<T>	Base class for implementing concatMapX main observers.
(package private) static final class	MaybeFlatMapObservable.FlatMapObserver<T,R>
(package private) static final class	ObservableConcatMapCompletable.ConcatMapCompletableObserver<T>
(package private) static final class	ObservableConcatMapMaybe.ConcatMapMaybeMainObserver<T,R>
(package private) static final class	ObservableConcatMapSingle.ConcatMapSingleMainObserver<T,R>
(package private) static final class	ObservableSwitchMapCompletable.SwitchMapCompletableObserver<T>
(package private) static final class	ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver<T,R>
(package private) static final class	ObservableSwitchMapSingle.SwitchMapSingleMainObserver<T,R>
(package private) static final class	SingleFlatMapObservable.FlatMapObserver<T,R>

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

Modifier and Type	Field	Description
(package private) final Observer<? super R>	CompletableAndThenObservable.AndThenObservableObserver.downstream
(package private) final Observer<? super R>	MaybeFlatMapObservable.FlatMapObserver.downstream
(package private) final Observer<? super R>	ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.downstream
(package private) final Observer<? super R>	ObservableConcatMapSingle.ConcatMapSingleMainObserver.downstream
(package private) final Observer<? super R>	ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver.downstream
(package private) final Observer<? super R>	ObservableSwitchMapSingle.SwitchMapSingleMainObserver.downstream
(package private) final Observer<? super R>	SingleFlatMapObservable.FlatMapObserver.downstream

Methods in io.reactivex.rxjava3.internal.operators.mixed with parameters of type Observer

Modifier and Type	Method	Description
protected void	CompletableAndThenObservable.subscribeActual(Observer<? super R> observer)
protected void	MaybeFlatMapObservable.subscribeActual(Observer<? super R> observer)
protected void	ObservableConcatMapMaybe.subscribeActual(Observer<? super R> observer)
protected void	ObservableConcatMapSingle.subscribeActual(Observer<? super R> observer)
protected void	ObservableSwitchMapMaybe.subscribeActual(Observer<? super R> observer)
protected void	ObservableSwitchMapSingle.subscribeActual(Observer<? super R> observer)
protected void	SingleFlatMapObservable.subscribeActual(Observer<? super R> observer)
(package private) static <T,R> boolean	ScalarXMapZHelper.tryAsMaybe(Object source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, Observer<? super R> observer)	Try subscribing to a MaybeSource mapped from a scalar source (which implements Supplier).
(package private) static <T,R> boolean	ScalarXMapZHelper.tryAsSingle(Object source, Function<? super T, ? extends SingleSource<? extends R>> mapper, Observer<? super R> observer)	Try subscribing to a SingleSource mapped from a scalar source (which implements Supplier).

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

Modifier	Constructor	Description
(package private)	AndThenObservableObserver(Observer<? super R> downstream, ObservableSource<? extends R> other)
(package private)	ConcatMapMaybeMainObserver(Observer<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, int prefetch, ErrorMode errorMode)
(package private)	ConcatMapSingleMainObserver(Observer<? super R> downstream, Function<? super T, ? extends SingleSource<? extends R>> mapper, int prefetch, ErrorMode errorMode)
(package private)	FlatMapObserver(Observer<? super R> downstream, Function<? super T, ? extends ObservableSource<? extends R>> mapper)
(package private)	FlatMapObserver(Observer<? super R> downstream, Function<? super T, ? extends ObservableSource<? extends R>> mapper)
(package private)	SwitchMapMaybeMainObserver(Observer<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors)
(package private)	SwitchMapSingleMainObserver(Observer<? super R> downstream, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayErrors)

Uses of Observer in io.reactivex.rxjava3.internal.operators.observable

Classes in io.reactivex.rxjava3.internal.operators.observable that implement Observer

Modifier and Type	Class	Description
(package private) static final class	BlockingObservableIterable.BlockingObservableIterator<T>
(package private) static final class	BlockingObservableLatest.BlockingObservableLatestIterator<T>
(package private) static final class	BlockingObservableMostRecent.MostRecentObserver<T>
(package private) static final class	BlockingObservableNext.NextObserver<T>
(package private) static final class	ObservableAll.AllObserver<T>
(package private) static final class	ObservableAllSingle.AllObserver<T>
(package private) static final class	ObservableAmb.AmbInnerObserver<T>
(package private) static final class	ObservableAny.AnyObserver<T>
(package private) static final class	ObservableAnySingle.AnyObserver<T>
(package private) static final class	ObservableBuffer.BufferExactObserver<T, U extends Collection<? super T>>
(package private) static final class	ObservableBuffer.BufferSkipObserver<T, U extends Collection<? super T>>
(package private) static final class	ObservableBufferBoundary.BufferBoundaryObserver<T, C extends Collection<? super T>, Open, Close>
(package private) static final class	ObservableBufferBoundary.BufferBoundaryObserver.BufferOpenObserver<Open>
(package private) static final class	ObservableBufferBoundary.BufferCloseObserver<T, C extends Collection<? super T>>
(package private) static final class	ObservableBufferExactBoundary.BufferBoundaryObserver<T, U extends Collection<? super T>, B>
(package private) static final class	ObservableBufferExactBoundary.BufferExactBoundaryObserver<T, U extends Collection<? super T>, B>
(package private) static final class	ObservableBufferTimed.BufferExactBoundedObserver<T, U extends Collection<? super T>>
(package private) static final class	ObservableBufferTimed.BufferExactUnboundedObserver<T, U extends Collection<? super T>>
(package private) static final class	ObservableBufferTimed.BufferSkipBoundedObserver<T, U extends Collection<? super T>>
final class	ObservableCache<T>	An observable which auto-connects to another observable, caches the elements from that observable but allows terminating the connection and completing the cache.
(package private) static final class	ObservableCollect.CollectObserver<T,U>
(package private) static final class	ObservableCollectSingle.CollectObserver<T,U>
(package private) static final class	ObservableCombineLatest.CombinerObserver<T,R>
(package private) static final class	ObservableConcatMap.ConcatMapDelayErrorObserver<T,R>
(package private) static final class	ObservableConcatMap.ConcatMapDelayErrorObserver.DelayErrorInnerObserver<R>
(package private) static final class	ObservableConcatMap.SourceObserver<T,U>
(package private) static final class	ObservableConcatMap.SourceObserver.InnerObserver<U>
(package private) static final class	ObservableConcatMapEager.ConcatMapEagerMainObserver<T,R>
(package private) static final class	ObservableConcatMapScheduler.ConcatMapDelayErrorObserver<T,R>
(package private) static final class	ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.DelayErrorInnerObserver<R>
(package private) static final class	ObservableConcatMapScheduler.ConcatMapObserver<T,U>
(package private) static final class	ObservableConcatMapScheduler.ConcatMapObserver.InnerObserver<U>
(package private) static final class	ObservableConcatWithCompletable.ConcatWithObserver<T>
(package private) static final class	ObservableConcatWithMaybe.ConcatWithObserver<T>
(package private) static final class	ObservableConcatWithSingle.ConcatWithObserver<T>
(package private) static final class	ObservableCount.CountObserver
(package private) static final class	ObservableCountSingle.CountObserver
(package private) static final class	ObservableDebounce.DebounceObserver<T,U>
(package private) static final class	ObservableDebounce.DebounceObserver.DebounceInnerObserver<T,U>
(package private) static final class	ObservableDebounceTimed.DebounceTimedObserver<T>
(package private) static final class	ObservableDelay.DelayObserver<T>
(package private) final class	ObservableDelaySubscriptionOther.DelayObserver
(package private) final class	ObservableDelaySubscriptionOther.DelayObserver.OnComplete
(package private) static final class	ObservableDematerialize.DematerializeObserver<T,R>
(package private) static final class	ObservableDetach.DetachObserver<T>
(package private) static final class	ObservableDistinct.DistinctObserver<T,K>
(package private) static final class	ObservableDistinctUntilChanged.DistinctUntilChangedObserver<T,K>
(package private) static final class	ObservableDoAfterNext.DoAfterObserver<T>
(package private) static final class	ObservableDoFinally.DoFinallyObserver<T>
(package private) static final class	ObservableDoOnEach.DoOnEachObserver<T>
(package private) static final class	ObservableElementAt.ElementAtObserver<T>
(package private) static final class	ObservableElementAtMaybe.ElementAtObserver<T>
(package private) static final class	ObservableElementAtSingle.ElementAtObserver<T>
(package private) static final class	ObservableFilter.FilterObserver<T>
(package private) static final class	ObservableFlatMap.InnerObserver<T,U>
(package private) static final class	ObservableFlatMap.MergeObserver<T,U>
(package private) static final class	ObservableFlatMapCompletable.FlatMapCompletableMainObserver<T>
(package private) static final class	ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver<T>
(package private) static final class	ObservableFlatMapMaybe.FlatMapMaybeObserver<T,R>
(package private) static final class	ObservableFlatMapSingle.FlatMapSingleObserver<T,R>
(package private) static final class	ObservableFlattenIterable.FlattenIterableObserver<T,R>
static final class	ObservableGroupBy.GroupByObserver<T,K,V>
(package private) static final class	ObservableGroupJoin.LeftRightEndObserver
(package private) static final class	ObservableGroupJoin.LeftRightObserver
(package private) static final class	ObservableHide.HideDisposable<T>
(package private) static final class	ObservableIgnoreElements.IgnoreObservable<T>
(package private) static final class	ObservableIgnoreElementsCompletable.IgnoreObservable<T>
(package private) static final class	ObservableLastMaybe.LastObserver<T>
(package private) static final class	ObservableLastSingle.LastObserver<T>
(package private) static final class	ObservableMap.MapObserver<T,U>
(package private) static final class	ObservableMapNotification.MapNotificationObserver<T,R>
(package private) static final class	ObservableMaterialize.MaterializeObserver<T>
(package private) static final class	ObservableMergeWithCompletable.MergeWithObserver<T>
(package private) static final class	ObservableMergeWithMaybe.MergeWithObserver<T>
(package private) static final class	ObservableMergeWithSingle.MergeWithObserver<T>
(package private) static final class	ObservableObserveOn.ObserveOnObserver<T>
static final class	ObservableOnErrorComplete.OnErrorCompleteObserver<T>
(package private) static final class	ObservableOnErrorNext.OnErrorNextObserver<T>
(package private) static final class	ObservableOnErrorReturn.OnErrorReturnObserver<T>
(package private) static final class	ObservablePublish.PublishConnection<T>
(package private) static final class	ObservablePublishSelector.SourceObserver<T>
(package private) static final class	ObservablePublishSelector.TargetObserver<R>
(package private) static final class	ObservableReduceMaybe.ReduceObserver<T>
(package private) static final class	ObservableReduceSeedSingle.ReduceSeedObserver<T,R>
(package private) static final class	ObservableRefCount.RefCountObserver<T>
(package private) static final class	ObservableRepeat.RepeatObserver<T>
(package private) static final class	ObservableRepeatUntil.RepeatUntilObserver<T>
(package private) static final class	ObservableRepeatWhen.RepeatWhenObserver<T>
(package private) final class	ObservableRepeatWhen.RepeatWhenObserver.InnerRepeatObserver
(package private) static final class	ObservableReplay.ReplayObserver<T>
(package private) static final class	ObservableRetryBiPredicate.RetryBiObserver<T>
(package private) static final class	ObservableRetryPredicate.RepeatObserver<T>
(package private) static final class	ObservableRetryWhen.RepeatWhenObserver<T>
(package private) final class	ObservableRetryWhen.RepeatWhenObserver.InnerRepeatObserver
(package private) static final class	ObservableSampleTimed.SampleTimedEmitLast<T>
(package private) static final class	ObservableSampleTimed.SampleTimedNoLast<T>
(package private) static class	ObservableSampleTimed.SampleTimedObserver<T>
(package private) static final class	ObservableSampleWithObservable.SampleMainEmitLast<T>
(package private) static final class	ObservableSampleWithObservable.SampleMainNoLast<T>
(package private) static class	ObservableSampleWithObservable.SampleMainObserver<T>
(package private) static final class	ObservableSampleWithObservable.SamplerObserver<T>
(package private) static final class	ObservableScan.ScanObserver<T>
(package private) static final class	ObservableScanSeed.ScanSeedObserver<T,R>
(package private) static final class	ObservableSequenceEqual.EqualObserver<T>
(package private) static final class	ObservableSequenceEqualSingle.EqualObserver<T>
(package private) static final class	ObservableSingleMaybe.SingleElementObserver<T>
(package private) static final class	ObservableSingleSingle.SingleElementObserver<T>
(package private) static final class	ObservableSkip.SkipObserver<T>
(package private) static final class	ObservableSkipLast.SkipLastObserver<T>
(package private) static final class	ObservableSkipLastTimed.SkipLastTimedObserver<T>
(package private) final class	ObservableSkipUntil.SkipUntil
(package private) static final class	ObservableSkipUntil.SkipUntilObserver<T>
(package private) static final class	ObservableSkipWhile.SkipWhileObserver<T>
(package private) static final class	ObservableSubscribeOn.SubscribeOnObserver<T>
(package private) static final class	ObservableSwitchIfEmpty.SwitchIfEmptyObserver<T>
(package private) static final class	ObservableSwitchMap.SwitchMapInnerObserver<T,R>
(package private) static final class	ObservableSwitchMap.SwitchMapObserver<T,R>
(package private) static final class	ObservableTake.TakeObserver<T>
(package private) static final class	ObservableTakeLast.TakeLastObserver<T>
(package private) static final class	ObservableTakeLastOne.TakeLastOneObserver<T>
(package private) static final class	ObservableTakeLastTimed.TakeLastTimedObserver<T>
(package private) static final class	ObservableTakeUntil.TakeUntilMainObserver<T,U>
(package private) final class	ObservableTakeUntil.TakeUntilMainObserver.OtherObserver
(package private) static final class	ObservableTakeUntilPredicate.TakeUntilPredicateObserver<T>
(package private) static final class	ObservableTakeWhile.TakeWhileObserver<T>
(package private) static final class	ObservableThrottleFirstTimed.DebounceTimedObserver<T>
(package private) static final class	ObservableThrottleLatest.ThrottleLatestObserver<T>
(package private) static final class	ObservableTimeInterval.TimeIntervalObserver<T>
(package private) static final class	ObservableTimeout.TimeoutConsumer
(package private) static final class	ObservableTimeout.TimeoutFallbackObserver<T>
(package private) static final class	ObservableTimeout.TimeoutObserver<T>
(package private) static final class	ObservableTimeoutTimed.FallbackObserver<T>
(package private) static final class	ObservableTimeoutTimed.TimeoutFallbackObserver<T>
(package private) static final class	ObservableTimeoutTimed.TimeoutObserver<T>
(package private) static final class	ObservableToList.ToListObserver<T, U extends Collection<? super T>>
(package private) static final class	ObservableToListSingle.ToListObserver<T, U extends Collection<? super T>>
(package private) static final class	ObservableUnsubscribeOn.UnsubscribeObserver<T>
(package private) static final class	ObservableUsing.UsingObserver<T,D>
(package private) static final class	ObservableWindow.WindowExactObserver<T>
(package private) static final class	ObservableWindow.WindowSkipObserver<T>
(package private) static final class	ObservableWindowBoundary.WindowBoundaryInnerObserver<T,B>
(package private) static final class	ObservableWindowBoundary.WindowBoundaryMainObserver<T,B>
(package private) static final class	ObservableWindowBoundarySelector.WindowBoundaryMainObserver<T,B,V>
(package private) static final class	ObservableWindowBoundarySelector.WindowBoundaryMainObserver.WindowEndObserverIntercept<T,V>
(package private) static final class	ObservableWindowBoundarySelector.WindowBoundaryMainObserver.WindowStartObserver<B>
(package private) static class	ObservableWindowTimed.AbstractWindowObserver<T>
(package private) static final class	ObservableWindowTimed.WindowExactBoundedObserver<T>
(package private) static final class	ObservableWindowTimed.WindowExactUnboundedObserver<T>
(package private) static final class	ObservableWindowTimed.WindowSkipObserver<T>
(package private) static final class	ObservableWithLatestFrom.WithLatestFromObserver<T,U,R>
(package private) final class	ObservableWithLatestFrom.WithLatestFromOtherObserver
(package private) static final class	ObservableWithLatestFromMany.WithLatestFromObserver<T,R>
(package private) static final class	ObservableWithLatestFromMany.WithLatestInnerObserver
(package private) static final class	ObservableZip.ZipObserver<T,R>
(package private) static final class	ObservableZipIterable.ZipIterableObserver<T,U,V>
final class	ObserverResourceWrapper<T>

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

Modifier and Type	Field	Description
(package private) final Observer<? super T>	ObservableDelaySubscriptionOther.DelayObserver.child
(package private) final Observer<? super T>	ObservableReplay.InnerDisposable.child	The actual child subscriber.
(package private) final Observer<? super Boolean>	ObservableAll.AllObserver.downstream
(package private) final Observer<? super T>	ObservableAmb.AmbCoordinator.downstream
(package private) final Observer<? super T>	ObservableAmb.AmbInnerObserver.downstream
(package private) final Observer<? super Boolean>	ObservableAny.AnyObserver.downstream
(package private) final Observer<? super U>	ObservableBuffer.BufferExactObserver.downstream
(package private) final Observer<? super U>	ObservableBuffer.BufferSkipObserver.downstream
(package private) final Observer<? super C>	ObservableBufferBoundary.BufferBoundaryObserver.downstream
(package private) final Observer<? super T>	ObservableCache.CacheDisposable.downstream
(package private) final Observer<? super U>	ObservableCollect.CollectObserver.downstream
(package private) final Observer<? super R>	ObservableCombineLatest.LatestCoordinator.downstream
(package private) final Observer<? super R>	ObservableConcatMap.ConcatMapDelayErrorObserver.DelayErrorInnerObserver.downstream
(package private) final Observer<? super R>	ObservableConcatMap.ConcatMapDelayErrorObserver.downstream
(package private) final Observer<? super U>	ObservableConcatMap.SourceObserver.downstream
(package private) final Observer<? super U>	ObservableConcatMap.SourceObserver.InnerObserver.downstream
(package private) final Observer<? super R>	ObservableConcatMapEager.ConcatMapEagerMainObserver.downstream
(package private) final Observer<? super R>	ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.DelayErrorInnerObserver.downstream
(package private) final Observer<? super R>	ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.downstream
(package private) final Observer<? super U>	ObservableConcatMapScheduler.ConcatMapObserver.downstream
(package private) final Observer<? super U>	ObservableConcatMapScheduler.ConcatMapObserver.InnerObserver.downstream
(package private) final Observer<? super T>	ObservableConcatWithCompletable.ConcatWithObserver.downstream
(package private) final Observer<? super T>	ObservableConcatWithMaybe.ConcatWithObserver.downstream
(package private) final Observer<? super T>	ObservableConcatWithSingle.ConcatWithObserver.downstream
(package private) final Observer<? super Long>	ObservableCount.CountObserver.downstream
(package private) final Observer<? super T>	ObservableDebounce.DebounceObserver.downstream
(package private) final Observer<? super T>	ObservableDebounceTimed.DebounceTimedObserver.downstream
(package private) final Observer<? super T>	ObservableDelay.DelayObserver.downstream
(package private) final Observer<? super R>	ObservableDematerialize.DematerializeObserver.downstream
(package private) Observer<? super T>	ObservableDetach.DetachObserver.downstream
(package private) final Observer<? super T>	ObservableDoFinally.DoFinallyObserver.downstream
(package private) final Observer<? super T>	ObservableDoOnEach.DoOnEachObserver.downstream
(package private) final Observer<? super T>	ObservableElementAt.ElementAtObserver.downstream
(package private) final Observer<? super U>	ObservableFlatMap.MergeObserver.downstream
(package private) final Observer<? super T>	ObservableFlatMapCompletable.FlatMapCompletableMainObserver.downstream
(package private) final Observer<? super R>	ObservableFlatMapMaybe.FlatMapMaybeObserver.downstream
(package private) final Observer<? super R>	ObservableFlatMapSingle.FlatMapSingleObserver.downstream
(package private) final Observer<? super R>	ObservableFlattenIterable.FlattenIterableObserver.downstream
(package private) final Observer<? super T>	ObservableFromArray.FromArrayDisposable.downstream
(package private) final Observer<? super T>	ObservableFromCompletable.FromCompletableObserver.downstream
(package private) final Observer<? super T>	ObservableFromIterable.FromIterableDisposable.downstream
(package private) final Observer<? super T>	ObservableFromPublisher.PublisherSubscriber.downstream
(package private) final Observer<? super T>	ObservableGenerate.GeneratorDisposable.downstream
(package private) final Observer<? super GroupedObservable<K,V>>	ObservableGroupBy.GroupByObserver.downstream
(package private) final Observer<? super R>	ObservableGroupJoin.GroupJoinDisposable.downstream
(package private) final Observer<? super T>	ObservableHide.HideDisposable.downstream
(package private) final Observer<? super T>	ObservableIgnoreElements.IgnoreObservable.downstream
(package private) final Observer<? super Long>	ObservableInterval.IntervalObserver.downstream
(package private) final Observer<? super Long>	ObservableIntervalRange.IntervalRangeObserver.downstream
(package private) final Observer<? super R>	ObservableJoin.JoinDisposable.downstream
(package private) final Observer<? super ObservableSource<? extends R>>	ObservableMapNotification.MapNotificationObserver.downstream
(package private) final Observer<? super Notification<T>>	ObservableMaterialize.MaterializeObserver.downstream
(package private) final Observer<? super T>	ObservableMergeWithCompletable.MergeWithObserver.downstream
(package private) final Observer<? super T>	ObservableMergeWithMaybe.MergeWithObserver.downstream
(package private) final Observer<? super T>	ObservableMergeWithSingle.MergeWithObserver.downstream
(package private) final Observer<? super T>	ObservableObserveOn.ObserveOnObserver.downstream
(package private) final Observer<? super T>	ObservableOnErrorComplete.OnErrorCompleteObserver.downstream
(package private) final Observer<? super T>	ObservableOnErrorNext.OnErrorNextObserver.downstream
(package private) final Observer<? super T>	ObservableOnErrorReturn.OnErrorReturnObserver.downstream
(package private) final Observer<? super T>	ObservablePublish.InnerDisposable.downstream
(package private) final Observer<? super R>	ObservablePublishSelector.TargetObserver.downstream
(package private) final Observer<? super Integer>	ObservableRange.RangeDisposable.downstream
(package private) final Observer<? super Long>	ObservableRangeLong.RangeDisposable.downstream
(package private) final Observer<? super T>	ObservableRefCount.RefCountObserver.downstream
(package private) final Observer<? super T>	ObservableRepeat.RepeatObserver.downstream
(package private) final Observer<? super T>	ObservableRepeatUntil.RepeatUntilObserver.downstream
(package private) final Observer<? super T>	ObservableRepeatWhen.RepeatWhenObserver.downstream
(package private) final Observer<? super T>	ObservableRetryBiPredicate.RetryBiObserver.downstream
(package private) final Observer<? super T>	ObservableRetryPredicate.RepeatObserver.downstream
(package private) final Observer<? super T>	ObservableRetryWhen.RepeatWhenObserver.downstream
(package private) final Observer<? super T>	ObservableSampleTimed.SampleTimedObserver.downstream
(package private) final Observer<? super T>	ObservableSampleWithObservable.SampleMainObserver.downstream
(package private) final Observer<? super T>	ObservableScan.ScanObserver.downstream
(package private) final Observer<? super R>	ObservableScanSeed.ScanSeedObserver.downstream
(package private) final Observer<? super Boolean>	ObservableSequenceEqual.EqualCoordinator.downstream
(package private) final Observer<? super T>	ObservableSkip.SkipObserver.downstream
(package private) final Observer<? super T>	ObservableSkipLast.SkipLastObserver.downstream
(package private) final Observer<? super T>	ObservableSkipLastTimed.SkipLastTimedObserver.downstream
(package private) final Observer<? super T>	ObservableSkipUntil.SkipUntilObserver.downstream
(package private) final Observer<? super T>	ObservableSkipWhile.SkipWhileObserver.downstream
(package private) final Observer<? super T>	ObservableSubscribeOn.SubscribeOnObserver.downstream
(package private) final Observer<? super T>	ObservableSwitchIfEmpty.SwitchIfEmptyObserver.downstream
(package private) final Observer<? super R>	ObservableSwitchMap.SwitchMapObserver.downstream
(package private) final Observer<? super T>	ObservableTake.TakeObserver.downstream
(package private) final Observer<? super T>	ObservableTakeLast.TakeLastObserver.downstream
(package private) final Observer<? super T>	ObservableTakeLastOne.TakeLastOneObserver.downstream
(package private) final Observer<? super T>	ObservableTakeLastTimed.TakeLastTimedObserver.downstream
(package private) final Observer<? super T>	ObservableTakeUntil.TakeUntilMainObserver.downstream
(package private) final Observer<? super T>	ObservableTakeUntilPredicate.TakeUntilPredicateObserver.downstream
(package private) final Observer<? super T>	ObservableTakeWhile.TakeWhileObserver.downstream
(package private) final Observer<? super T>	ObservableThrottleFirstTimed.DebounceTimedObserver.downstream
(package private) final Observer<? super T>	ObservableThrottleLatest.ThrottleLatestObserver.downstream
(package private) final Observer<? super Timed<T>>	ObservableTimeInterval.TimeIntervalObserver.downstream
(package private) final Observer<? super T>	ObservableTimeout.TimeoutFallbackObserver.downstream
(package private) final Observer<? super T>	ObservableTimeout.TimeoutObserver.downstream
(package private) final Observer<? super T>	ObservableTimeoutTimed.FallbackObserver.downstream
(package private) final Observer<? super T>	ObservableTimeoutTimed.TimeoutFallbackObserver.downstream
(package private) final Observer<? super T>	ObservableTimeoutTimed.TimeoutObserver.downstream
(package private) final Observer<? super Long>	ObservableTimer.TimerObserver.downstream
(package private) final Observer<? super U>	ObservableToList.ToListObserver.downstream
(package private) final Observer<? super T>	ObservableUnsubscribeOn.UnsubscribeObserver.downstream
(package private) final Observer<? super T>	ObservableUsing.UsingObserver.downstream
(package private) final Observer<? super Observable<T>>	ObservableWindow.WindowExactObserver.downstream
(package private) final Observer<? super Observable<T>>	ObservableWindow.WindowSkipObserver.downstream
(package private) final Observer<? super Observable<T>>	ObservableWindowBoundary.WindowBoundaryMainObserver.downstream
(package private) final Observer<? super Observable<T>>	ObservableWindowBoundarySelector.WindowBoundaryMainObserver.downstream
(package private) final Observer<? super Observable<T>>	ObservableWindowTimed.AbstractWindowObserver.downstream
(package private) final Observer<? super R>	ObservableWithLatestFrom.WithLatestFromObserver.downstream
(package private) final Observer<? super R>	ObservableWithLatestFromMany.WithLatestFromObserver.downstream
(package private) final Observer<? super R>	ObservableZip.ZipCoordinator.downstream
(package private) final Observer<? super V>	ObservableZipIterable.ZipIterableObserver.downstream
(package private) final Observer<? super T>	ObserverResourceWrapper.downstream
(package private) final Observer<? super T>	ObservableCreate.CreateEmitter.observer
(package private) final Observer<T>	ObservableInternalHelper.ObserverOnComplete.observer
(package private) final Observer<T>	ObservableInternalHelper.ObserverOnError.observer
(package private) final Observer<T>	ObservableInternalHelper.ObserverOnNext.observer
(package private) final Observer<? super T>	ObservableScalarXMap.ScalarDisposable.observer

Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type Observer

Modifier and Type	Field	Description
(package private) final AtomicReference<Observer<? super T>>	ObservableGroupBy.State.actual

Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type Observer

Modifier and Type	Method	Description
void	ObservableBufferExactBoundary.BufferExactBoundaryObserver.accept(Observer<? super U> a, U v)
void	ObservableBufferTimed.BufferExactBoundedObserver.accept(Observer<? super U> a, U v)
void	ObservableBufferTimed.BufferExactUnboundedObserver.accept(Observer<? super U> a, U v)
void	ObservableBufferTimed.BufferSkipBoundedObserver.accept(Observer<? super U> a, U v)
(package private) boolean	ObservableGroupBy.State.checkTerminated(boolean d, boolean empty, Observer<? super T> a, boolean delayError)
(package private) boolean	ObservableObserveOn.ObserveOnObserver.checkTerminated(boolean d, boolean empty, Observer<? super T> a)
(package private) boolean	ObservableZip.ZipCoordinator.checkTerminated(boolean d, boolean empty, Observer<? super R> a, boolean delayError, ObservableZip.ZipObserver<?,?> source)
(package private) void	ObservableGroupJoin.GroupJoinDisposable.errorAll(Observer<?> a)
(package private) void	ObservableJoin.JoinDisposable.errorAll(Observer<?> a)
(package private) void	ObservableGroupJoin.GroupJoinDisposable.fail(Throwable exc, Observer<?> a, SpscLinkedArrayQueue<?> q)
(package private) void	ObservableJoin.JoinDisposable.fail(Throwable exc, Observer<?> a, SpscLinkedArrayQueue<?> q)
static <T> Action	ObservableInternalHelper.observerOnComplete(Observer<T> observer)
static <T> Consumer<Throwable>	ObservableInternalHelper.observerOnError(Observer<T> observer)
static <T> Consumer<T>	ObservableInternalHelper.observerOnNext(Observer<T> observer)
static <T> void	ObservableBlockingSubscribe.subscribe(ObservableSource<? extends T> o, Observer<? super T> observer)	Subscribes to the source and calls the Observer methods on the current thread.
void	ObservableGroupBy.State.subscribe(Observer<? super T> observer)
void	ObservableReplay.ReplaySource.subscribe(Observer<? super T> child)
protected void	ObservableAll.subscribeActual(Observer<? super Boolean> t)
void	ObservableAmb.subscribeActual(Observer<? super T> observer)
protected void	ObservableAny.subscribeActual(Observer<? super Boolean> t)
void	ObservableAutoConnect.subscribeActual(Observer<? super T> child)
protected void	ObservableBuffer.subscribeActual(Observer<? super U> t)
protected void	ObservableBufferBoundary.subscribeActual(Observer<? super U> t)
protected void	ObservableBufferExactBoundary.subscribeActual(Observer<? super U> t)
protected void	ObservableBufferTimed.subscribeActual(Observer<? super U> t)
protected void	ObservableCache.subscribeActual(Observer<? super T> t)
protected void	ObservableCollect.subscribeActual(Observer<? super U> t)
void	ObservableCombineLatest.subscribeActual(Observer<? super R> observer)
void	ObservableConcatMap.subscribeActual(Observer<? super U> observer)
protected void	ObservableConcatMapEager.subscribeActual(Observer<? super R> observer)
void	ObservableConcatMapScheduler.subscribeActual(Observer<? super U> observer)
protected void	ObservableConcatWithCompletable.subscribeActual(Observer<? super T> observer)
protected void	ObservableConcatWithMaybe.subscribeActual(Observer<? super T> observer)
protected void	ObservableConcatWithSingle.subscribeActual(Observer<? super T> observer)
void	ObservableCount.subscribeActual(Observer<? super Long> t)
protected void	ObservableCreate.subscribeActual(Observer<? super T> observer)
void	ObservableDebounce.subscribeActual(Observer<? super T> t)
void	ObservableDebounceTimed.subscribeActual(Observer<? super T> t)
void	ObservableDefer.subscribeActual(Observer<? super T> observer)
void	ObservableDelay.subscribeActual(Observer<? super T> t)
void	ObservableDelaySubscriptionOther.subscribeActual(Observer<? super T> child)
void	ObservableDematerialize.subscribeActual(Observer<? super R> observer)
protected void	ObservableDetach.subscribeActual(Observer<? super T> observer)
protected void	ObservableDistinct.subscribeActual(Observer<? super T> observer)
protected void	ObservableDistinctUntilChanged.subscribeActual(Observer<? super T> observer)
protected void	ObservableDoAfterNext.subscribeActual(Observer<? super T> observer)
protected void	ObservableDoFinally.subscribeActual(Observer<? super T> observer)
void	ObservableDoOnEach.subscribeActual(Observer<? super T> t)
protected void	ObservableDoOnLifecycle.subscribeActual(Observer<? super T> observer)
void	ObservableElementAt.subscribeActual(Observer<? super T> t)
protected void	ObservableEmpty.subscribeActual(Observer<? super Object> o)
void	ObservableError.subscribeActual(Observer<? super T> observer)
void	ObservableFilter.subscribeActual(Observer<? super T> observer)
void	ObservableFlatMap.subscribeActual(Observer<? super U> t)
protected void	ObservableFlatMapCompletable.subscribeActual(Observer<? super T> observer)
protected void	ObservableFlatMapMaybe.subscribeActual(Observer<? super R> observer)
protected void	ObservableFlatMapSingle.subscribeActual(Observer<? super R> observer)
protected void	ObservableFlattenIterable.subscribeActual(Observer<? super R> observer)
protected void	ObservableFromAction.subscribeActual(Observer<? super T> observer)
void	ObservableFromArray.subscribeActual(Observer<? super T> observer)
void	ObservableFromCallable.subscribeActual(Observer<? super T> observer)
protected void	ObservableFromCompletable.subscribeActual(Observer<? super T> observer)
void	ObservableFromFuture.subscribeActual(Observer<? super T> observer)
void	ObservableFromIterable.subscribeActual(Observer<? super T> observer)
protected void	ObservableFromPublisher.subscribeActual(Observer<? super T> o)
protected void	ObservableFromRunnable.subscribeActual(Observer<? super T> observer)
void	ObservableFromSupplier.subscribeActual(Observer<? super T> observer)
protected void	ObservableFromUnsafeSource.subscribeActual(Observer<? super T> observer)
void	ObservableGenerate.subscribeActual(Observer<? super T> observer)
protected void	ObservableGroupBy.GroupedUnicast.subscribeActual(Observer<? super T> observer)
void	ObservableGroupBy.subscribeActual(Observer<? super GroupedObservable<K,V>> t)
protected void	ObservableGroupJoin.subscribeActual(Observer<? super R> observer)
protected void	ObservableHide.subscribeActual(Observer<? super T> o)
void	ObservableIgnoreElements.subscribeActual(Observer<? super T> t)
void	ObservableInterval.subscribeActual(Observer<? super Long> observer)
void	ObservableIntervalRange.subscribeActual(Observer<? super Long> observer)
protected void	ObservableJoin.subscribeActual(Observer<? super R> observer)
protected void	ObservableJust.subscribeActual(Observer<? super T> observer)
void	ObservableLift.subscribeActual(Observer<? super R> observer)
void	ObservableMap.subscribeActual(Observer<? super U> t)
void	ObservableMapNotification.subscribeActual(Observer<? super ObservableSource<? extends R>> t)
void	ObservableMaterialize.subscribeActual(Observer<? super Notification<T>> t)
protected void	ObservableMergeWithCompletable.subscribeActual(Observer<? super T> observer)
protected void	ObservableMergeWithMaybe.subscribeActual(Observer<? super T> observer)
protected void	ObservableMergeWithSingle.subscribeActual(Observer<? super T> observer)
protected void	ObservableNever.subscribeActual(Observer<? super Object> o)
protected void	ObservableObserveOn.subscribeActual(Observer<? super T> observer)
protected void	ObservableOnErrorComplete.subscribeActual(Observer<? super T> observer)
void	ObservableOnErrorNext.subscribeActual(Observer<? super T> t)
void	ObservableOnErrorReturn.subscribeActual(Observer<? super T> t)
protected void	ObservablePublish.subscribeActual(Observer<? super T> observer)
protected void	ObservablePublishSelector.subscribeActual(Observer<? super R> observer)
protected void	ObservableRange.subscribeActual(Observer<? super Integer> o)
protected void	ObservableRangeLong.subscribeActual(Observer<? super Long> o)
protected void	ObservableRefCount.subscribeActual(Observer<? super T> observer)
void	ObservableRepeat.subscribeActual(Observer<? super T> observer)
void	ObservableRepeatUntil.subscribeActual(Observer<? super T> observer)
protected void	ObservableRepeatWhen.subscribeActual(Observer<? super T> observer)
protected void	ObservableReplay.MulticastReplay.subscribeActual(Observer<? super R> child)
protected void	ObservableReplay.subscribeActual(Observer<? super T> observer)
void	ObservableRetryBiPredicate.subscribeActual(Observer<? super T> observer)
void	ObservableRetryPredicate.subscribeActual(Observer<? super T> observer)
protected void	ObservableRetryWhen.subscribeActual(Observer<? super T> observer)
void	ObservableSampleTimed.subscribeActual(Observer<? super T> t)
void	ObservableSampleWithObservable.subscribeActual(Observer<? super T> t)
void	ObservableScalarXMap.ScalarXMapObservable.subscribeActual(Observer<? super R> observer)
void	ObservableScan.subscribeActual(Observer<? super T> t)
void	ObservableScanSeed.subscribeActual(Observer<? super R> t)
void	ObservableSequenceEqual.subscribeActual(Observer<? super Boolean> observer)
protected void	ObservableSerialized.subscribeActual(Observer<? super T> observer)
void	ObservableSkip.subscribeActual(Observer<? super T> observer)
void	ObservableSkipLast.subscribeActual(Observer<? super T> observer)
void	ObservableSkipLastTimed.subscribeActual(Observer<? super T> t)
void	ObservableSkipUntil.subscribeActual(Observer<? super T> child)
void	ObservableSkipWhile.subscribeActual(Observer<? super T> observer)
void	ObservableSubscribeOn.subscribeActual(Observer<? super T> observer)
void	ObservableSwitchIfEmpty.subscribeActual(Observer<? super T> t)
void	ObservableSwitchMap.subscribeActual(Observer<? super R> t)
protected void	ObservableTake.subscribeActual(Observer<? super T> observer)
void	ObservableTakeLast.subscribeActual(Observer<? super T> t)
void	ObservableTakeLastOne.subscribeActual(Observer<? super T> observer)
void	ObservableTakeLastTimed.subscribeActual(Observer<? super T> t)
void	ObservableTakeUntil.subscribeActual(Observer<? super T> child)
void	ObservableTakeUntilPredicate.subscribeActual(Observer<? super T> observer)
void	ObservableTakeWhile.subscribeActual(Observer<? super T> t)
void	ObservableThrottleFirstTimed.subscribeActual(Observer<? super T> t)
protected void	ObservableThrottleLatest.subscribeActual(Observer<? super T> observer)
void	ObservableTimeInterval.subscribeActual(Observer<? super Timed<T>> t)
protected void	ObservableTimeout.subscribeActual(Observer<? super T> observer)
protected void	ObservableTimeoutTimed.subscribeActual(Observer<? super T> observer)
void	ObservableTimer.subscribeActual(Observer<? super Long> observer)
void	ObservableToList.subscribeActual(Observer<? super U> t)
void	ObservableUnsubscribeOn.subscribeActual(Observer<? super T> t)
void	ObservableUsing.subscribeActual(Observer<? super T> observer)
void	ObservableWindow.subscribeActual(Observer<? super Observable<T>> t)
void	ObservableWindowBoundary.subscribeActual(Observer<? super Observable<T>> observer)
void	ObservableWindowBoundarySelector.subscribeActual(Observer<? super Observable<T>> t)
protected void	ObservableWindowBoundarySelector.WindowBoundaryMainObserver.WindowEndObserverIntercept.subscribeActual(Observer<? super T> o)
protected void	ObservableWindowSubscribeIntercept.subscribeActual(Observer<? super T> s)
protected void	ObservableWindowTimed.subscribeActual(Observer<? super Observable<T>> downstream)
void	ObservableWithLatestFrom.subscribeActual(Observer<? super R> t)
protected void	ObservableWithLatestFromMany.subscribeActual(Observer<? super R> observer)
void	ObservableZip.subscribeActual(Observer<? super R> observer)
void	ObservableZipIterable.subscribeActual(Observer<? super V> t)
(package private) void	ObservableWindowBoundarySelector.WindowBoundaryMainObserver.terminateDownstream(Observer<?> downstream)
static <T,R> boolean	ObservableScalarXMap.tryScalarXMapSubscribe(ObservableSource<T> source, Observer<? super R> observer, Function<? super T, ? extends ObservableSource<? extends R>> mapper)	Tries to subscribe to a possibly Supplier source's mapped ObservableSource.

Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type Observer

Modifier	Constructor	Description
(package private)	AbstractWindowObserver(Observer<? super Observable<T>> downstream, long timespan, TimeUnit unit, int bufferSize)
(package private)	AllObserver(Observer<? super Boolean> actual, Predicate<? super T> predicate)
(package private)	AmbCoordinator(Observer<? super T> actual, int count)
(package private)	AmbInnerObserver(ObservableAmb.AmbCoordinator<T> parent, int index, Observer<? super T> downstream)
(package private)	AnyObserver(Observer<? super Boolean> actual, Predicate<? super T> predicate)
(package private)	BufferBoundaryObserver(Observer<? super C> actual, ObservableSource<? extends Open> bufferOpen, Function<? super Open, ? extends ObservableSource<? extends Close>> bufferClose, Supplier<C> bufferSupplier)
(package private)	BufferExactBoundaryObserver(Observer<? super U> actual, Supplier<U> bufferSupplier, ObservableSource<B> boundary)
(package private)	BufferExactBoundedObserver(Observer<? super U> actual, Supplier<U> bufferSupplier, long timespan, TimeUnit unit, int maxSize, boolean restartOnMaxSize, Scheduler.Worker w)
(package private)	BufferExactObserver(Observer<? super U> actual, int count, Supplier<U> bufferSupplier)
(package private)	BufferExactUnboundedObserver(Observer<? super U> actual, Supplier<U> bufferSupplier, long timespan, TimeUnit unit, Scheduler scheduler)
(package private)	BufferSkipBoundedObserver(Observer<? super U> actual, Supplier<U> bufferSupplier, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker w)
(package private)	BufferSkipObserver(Observer<? super U> actual, int count, int skip, Supplier<U> bufferSupplier)
(package private)	CacheDisposable(Observer<? super T> downstream, ObservableCache<T> parent)	Constructs a new instance with the actual downstream consumer and the parent cache object.
(package private)	CollectObserver(Observer<? super U> actual, U u, BiConsumer<? super U, ? super T> collector)
(package private)	ConcatMapDelayErrorObserver(Observer<? super R> actual, Function<? super T, ? extends ObservableSource<? extends R>> mapper, int bufferSize, boolean tillTheEnd)
(package private)	ConcatMapDelayErrorObserver(Observer<? super R> actual, Function<? super T, ? extends ObservableSource<? extends R>> mapper, int bufferSize, boolean tillTheEnd, Scheduler.Worker worker)
(package private)	ConcatMapEagerMainObserver(Observer<? super R> actual, Function<? super T, ? extends ObservableSource<? extends R>> mapper, int maxConcurrency, int prefetch, ErrorMode errorMode)
(package private)	ConcatMapObserver(Observer<? super U> actual, Function<? super T, ? extends ObservableSource<? extends U>> mapper, int bufferSize, Scheduler.Worker worker)
(package private)	ConcatWithObserver(Observer<? super T> actual, CompletableSource other)
(package private)	ConcatWithObserver(Observer<? super T> actual, MaybeSource<? extends T> other)
(package private)	ConcatWithObserver(Observer<? super T> actual, SingleSource<? extends T> other)
(package private)	CountObserver(Observer<? super Long> downstream)
(package private)	CreateEmitter(Observer<? super T> observer)
(package private)	DebounceObserver(Observer<? super T> actual, Function<? super T, ? extends ObservableSource<U>> debounceSelector)
(package private)	DebounceTimedObserver(Observer<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped)
(package private)	DebounceTimedObserver(Observer<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped)
(package private)	DelayErrorInnerObserver(Observer<? super R> actual, ObservableConcatMap.ConcatMapDelayErrorObserver<?,R> parent)
(package private)	DelayErrorInnerObserver(Observer<? super R> actual, ObservableConcatMapScheduler.ConcatMapDelayErrorObserver<?,R> parent)
(package private)	DelayObserver(Observer<? super T> actual, long delay, TimeUnit unit, Scheduler.Worker w, boolean delayError)
(package private)	DelayObserver(SequentialDisposable serial, Observer<? super T> child)
(package private)	DematerializeObserver(Observer<? super R> downstream, Function<? super T, ? extends Notification<R>> selector)
(package private)	DetachObserver(Observer<? super T> downstream)
(package private)	DistinctObserver(Observer<? super T> actual, Function<? super T, K> keySelector, Collection<? super K> collection)
(package private)	DistinctUntilChangedObserver(Observer<? super T> actual, Function<? super T, K> keySelector, BiPredicate<? super K, ? super K> comparer)
(package private)	DoAfterObserver(Observer<? super T> actual, Consumer<? super T> onAfterNext)
(package private)	DoFinallyObserver(Observer<? super T> actual, Action onFinally)
(package private)	DoOnEachObserver(Observer<? super T> actual, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Action onAfterTerminate)
(package private)	ElementAtObserver(Observer<? super T> actual, long index, T defaultValue, boolean errorOnFewer)
(package private)	EqualCoordinator(Observer<? super Boolean> actual, int bufferSize, ObservableSource<? extends T> first, ObservableSource<? extends T> second, BiPredicate<? super T, ? super T> comparer)
(package private)	FallbackObserver(Observer<? super T> actual, AtomicReference<Disposable> arbiter)
(package private)	FilterObserver(Observer<? super T> actual, Predicate<? super T> filter)
(package private)	FlatMapCompletableMainObserver(Observer<? super T> observer, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors)
(package private)	FlatMapMaybeObserver(Observer<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors)
(package private)	FlatMapSingleObserver(Observer<? super R> actual, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayErrors)
(package private)	FlattenIterableObserver(Observer<? super R> actual, Function<? super T, ? extends Iterable<? extends R>> mapper)
(package private)	FromArrayDisposable(Observer<? super T> actual, T[] array)
	FromCompletableObserver(Observer<? super T> downstream)
(package private)	FromIterableDisposable(Observer<? super T> actual, Iterator<? extends T> it)
(package private)	GeneratorDisposable(Observer<? super T> actual, BiFunction<S, ? super Emitter<T>, S> generator, Consumer<? super S> disposeState, S initialState)
	GroupByObserver(Observer<? super GroupedObservable<K,V>> actual, Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, int bufferSize, boolean delayError)
(package private)	GroupJoinDisposable(Observer<? super R> actual, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super Observable<TRight>, ? extends R> resultSelector)
(package private)	HideDisposable(Observer<? super T> downstream)
(package private)	IgnoreObservable(Observer<? super T> t)
(package private)	InnerDisposable(Observer<? super T> downstream, ObservablePublish.PublishConnection<T> parent)
(package private)	InnerDisposable(ObservableReplay.ReplayObserver<T> parent, Observer<? super T> child)
(package private)	InnerObserver(Observer<? super U> actual, ObservableConcatMap.SourceObserver<?,?> parent)
(package private)	InnerObserver(Observer<? super U> actual, ObservableConcatMapScheduler.ConcatMapObserver<?,?> parent)
(package private)	IntervalObserver(Observer<? super Long> downstream)
(package private)	IntervalRangeObserver(Observer<? super Long> actual, long start, long end)
(package private)	JoinDisposable(Observer<? super R> actual, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector)
(package private)	LatestCoordinator(Observer<? super R> actual, Function<? super Object[], ? extends R> combiner, int count, int bufferSize, boolean delayError)
(package private)	MapNotificationObserver(Observer<? super ObservableSource<? extends R>> actual, Function<? super T, ? extends ObservableSource<? extends R>> onNextMapper, Function<? super Throwable, ? extends ObservableSource<? extends R>> onErrorMapper, Supplier<? extends ObservableSource<? extends R>> onCompleteSupplier)
(package private)	MapObserver(Observer<? super U> actual, Function<? super T, ? extends U> mapper)
(package private)	MaterializeObserver(Observer<? super Notification<T>> downstream)
(package private)	MergeObserver(Observer<? super U> actual, Function<? super T, ? extends ObservableSource<? extends U>> mapper, boolean delayErrors, int maxConcurrency, int bufferSize)
(package private)	MergeWithObserver(Observer<? super T> downstream)
(package private)	MergeWithObserver(Observer<? super T> downstream)
(package private)	MergeWithObserver(Observer<? super T> downstream)
(package private)	ObserveOnObserver(Observer<? super T> actual, Scheduler.Worker worker, boolean delayError, int bufferSize)
(package private)	ObserverOnComplete(Observer<T> observer)
(package private)	ObserverOnError(Observer<T> observer)
(package private)	ObserverOnNext(Observer<T> observer)
	ObserverResourceWrapper(Observer<? super T> downstream)
	OnErrorCompleteObserver(Observer<? super T> actual, Predicate<? super Throwable> predicate)
(package private)	OnErrorNextObserver(Observer<? super T> actual, Function<? super Throwable, ? extends ObservableSource<? extends T>> nextSupplier)
(package private)	OnErrorReturnObserver(Observer<? super T> actual, Function<? super Throwable, ? extends T> valueSupplier)
(package private)	PublisherSubscriber(Observer<? super T> o)
(package private)	RangeDisposable(Observer<? super Integer> actual, long start, long end)
(package private)	RangeDisposable(Observer<? super Long> actual, long start, long end)
(package private)	RefCountObserver(Observer<? super T> downstream, ObservableRefCount<T> parent, ObservableRefCount.RefConnection connection)
(package private)	RepeatObserver(Observer<? super T> actual, long count, SequentialDisposable sd, ObservableSource<? extends T> source)
(package private)	RepeatObserver(Observer<? super T> actual, long count, Predicate<? super Throwable> predicate, SequentialDisposable sa, ObservableSource<? extends T> source)
(package private)	RepeatUntilObserver(Observer<? super T> actual, BooleanSupplier until, SequentialDisposable sd, ObservableSource<? extends T> source)
(package private)	RepeatWhenObserver(Observer<? super T> actual, Subject<Object> signaller, ObservableSource<T> source)
(package private)	RepeatWhenObserver(Observer<? super T> actual, Subject<Throwable> signaller, ObservableSource<T> source)
(package private)	RetryBiObserver(Observer<? super T> actual, BiPredicate<? super Integer, ? super Throwable> predicate, SequentialDisposable sa, ObservableSource<? extends T> source)
(package private)	SampleMainEmitLast(Observer<? super T> actual, ObservableSource<?> other)
(package private)	SampleMainNoLast(Observer<? super T> actual, ObservableSource<?> other)
(package private)	SampleMainObserver(Observer<? super T> actual, ObservableSource<?> other)
(package private)	SampleTimedEmitLast(Observer<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped)
(package private)	SampleTimedNoLast(Observer<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped)
(package private)	SampleTimedObserver(Observer<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped)
	ScalarDisposable(Observer<? super T> observer, T value)
(package private)	ScanObserver(Observer<? super T> actual, BiFunction<T,T,T> accumulator)
(package private)	ScanSeedObserver(Observer<? super R> actual, BiFunction<R, ? super T, R> accumulator, R value)
(package private)	SkipLastObserver(Observer<? super T> actual, int skip)
(package private)	SkipLastTimedObserver(Observer<? super T> actual, long time, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean delayError)
(package private)	SkipObserver(Observer<? super T> actual, long n)
(package private)	SkipUntilObserver(Observer<? super T> actual, ArrayCompositeDisposable frc)
(package private)	SkipWhileObserver(Observer<? super T> actual, Predicate<? super T> predicate)
(package private)	SourceObserver(Observer<? super U> actual, Function<? super T, ? extends ObservableSource<? extends U>> mapper, int bufferSize)
(package private)	SubscribeOnObserver(Observer<? super T> downstream)
(package private)	SwitchIfEmptyObserver(Observer<? super T> actual, ObservableSource<? extends T> other)
(package private)	SwitchMapObserver(Observer<? super R> actual, Function<? super T, ? extends ObservableSource<? extends R>> mapper, int bufferSize, boolean delayErrors)
(package private)	TakeLastObserver(Observer<? super T> actual, int count)
(package private)	TakeLastOneObserver(Observer<? super T> downstream)
(package private)	TakeLastTimedObserver(Observer<? super T> actual, long count, long time, TimeUnit unit, Scheduler scheduler, int bufferSize, boolean delayError)
(package private)	TakeObserver(Observer<? super T> actual, long limit)
(package private)	TakeUntilMainObserver(Observer<? super T> downstream)
(package private)	TakeUntilPredicateObserver(Observer<? super T> downstream, Predicate<? super T> predicate)
(package private)	TakeWhileObserver(Observer<? super T> actual, Predicate<? super T> predicate)
(package private)	TargetObserver(Observer<? super R> downstream)
(package private)	ThrottleLatestObserver(Observer<? super T> downstream, long timeout, TimeUnit unit, Scheduler.Worker worker, boolean emitLast, Consumer<? super T> onDropped)
(package private)	TimeIntervalObserver(Observer<? super Timed<T>> actual, TimeUnit unit, Scheduler scheduler)
(package private)	TimeoutFallbackObserver(Observer<? super T> actual, Function<? super T, ? extends ObservableSource<?>> itemTimeoutIndicator, ObservableSource<? extends T> fallback)
(package private)	TimeoutFallbackObserver(Observer<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, ObservableSource<? extends T> fallback)
(package private)	TimeoutObserver(Observer<? super T> actual, Function<? super T, ? extends ObservableSource<?>> itemTimeoutIndicator)
(package private)	TimeoutObserver(Observer<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker)
(package private)	TimerObserver(Observer<? super Long> downstream)
(package private)	ToListObserver(Observer<? super U> actual, U collection)
(package private)	UnsubscribeObserver(Observer<? super T> actual, Scheduler scheduler)
(package private)	UsingObserver(Observer<? super T> actual, D resource, Consumer<? super D> disposer, boolean eager)
(package private)	WindowBoundaryMainObserver(Observer<? super Observable<T>> downstream, int capacityHint)
(package private)	WindowBoundaryMainObserver(Observer<? super Observable<T>> downstream, ObservableSource<B> open, Function<? super B, ? extends ObservableSource<V>> closingIndicator, int bufferSize)
(package private)	WindowExactBoundedObserver(Observer<? super Observable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize, long maxSize, boolean restartTimerOnMaxSize)
(package private)	WindowExactObserver(Observer<? super Observable<T>> actual, long count, int capacityHint)
(package private)	WindowExactUnboundedObserver(Observer<? super Observable<T>> actual, long timespan, TimeUnit unit, Scheduler scheduler, int bufferSize)
(package private)	WindowSkipObserver(Observer<? super Observable<T>> actual, long count, long skip, int capacityHint)
(package private)	WindowSkipObserver(Observer<? super Observable<T>> actual, long timespan, long timeskip, TimeUnit unit, Scheduler.Worker worker, int bufferSize)
(package private)	WithLatestFromObserver(Observer<? super R> actual, BiFunction<? super T, ? super U, ? extends R> combiner)
(package private)	WithLatestFromObserver(Observer<? super R> actual, Function<? super Object[], R> combiner, int n)
(package private)	ZipCoordinator(Observer<? super R> actual, Function<? super Object[], ? extends R> zipper, int count, boolean delayError)
(package private)	ZipIterableObserver(Observer<? super V> actual, Iterator<U> iterator, BiFunction<? super T, ? super U, ? extends V> zipper)

Uses of Observer in io.reactivex.rxjava3.internal.operators.single

Classes in io.reactivex.rxjava3.internal.operators.single that implement Observer

Modifier and Type	Class	Description
(package private) static final class	SingleDelayWithObservable.OtherSubscriber<T,U>

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

Modifier and Type	Field	Description
(package private) final Observer<? super R>	SingleFlatMapIterableObservable.FlatMapIterableObserver.downstream

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

Modifier and Type	Method	Description
static <T> SingleObserver<T>	SingleToObservable.create(Observer<? super T> downstream)	Creates a SingleObserver wrapper around a Observer.
protected void	SingleFlatMapIterableObservable.subscribeActual(Observer<? super R> observer)
void	SingleToObservable.subscribeActual(Observer<? super T> observer)

Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type Observer

Modifier	Constructor	Description
(package private)	FlatMapIterableObserver(Observer<? super R> actual, Function<? super T, ? extends Iterable<? extends R>> mapper)
(package private)	SingleToObservableObserver(Observer<? super T> downstream)

Uses of Observer in io.reactivex.rxjava3.internal.util

Classes in io.reactivex.rxjava3.internal.util that implement Observer

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

Methods in io.reactivex.rxjava3.internal.util that return Observer

Modifier and Type	Method	Description
static <T> Observer<T>	EmptyComponent.asObserver()

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

Modifier and Type	Method	Description
<U> boolean	AppendOnlyLinkedArrayList.accept(Observer<? super U> observer)	Interprets the contents as NotificationLite objects and calls the appropriate Observer method.
static <T> boolean	NotificationLite.accept(Object o, Observer<? super T> observer)	Calls the appropriate Observer method based on the type of the notification.
void	ObservableQueueDrain.accept(Observer<? super U> a, T v)	Accept the value and return true if forwarded.
static <T> boolean	NotificationLite.acceptFull(Object o, Observer<? super T> observer)	Calls the appropriate Observer method based on the type of the notification.
static <T,U> boolean	QueueDrainHelper.checkTerminated(boolean d, boolean empty, Observer<?> observer, boolean delayError, SimpleQueue<?> q, Disposable disposable, ObservableQueueDrain<T,U> qd)
static <T,U> void	QueueDrainHelper.drainLoop(SimplePlainQueue<T> q, Observer<? super U> a, boolean delayError, Disposable dispose, ObservableQueueDrain<T,U> qd)
static void	HalfSerializer.onComplete(Observer<?> observer, AtomicInteger wip, AtomicThrowable errors)	Emits an onComplete signal or an onError signal with the given error or indicates the concurrently running onNext should do that.
static void	HalfSerializer.onError(Observer<?> observer, Throwable ex, AtomicInteger wip, AtomicThrowable errors)	Emits the given exception if possible or adds it to the given error container to be emitted by a concurrent onNext if one is running.
static <T> void	HalfSerializer.onNext(Observer<? super T> observer, T value, AtomicInteger wip, AtomicThrowable errors)	Emits the given value if possible and terminates if there was an onComplete or onError while emitting, drops the value otherwise.
void	AtomicThrowable.tryTerminateConsumer(Observer<?> 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 Observer in io.reactivex.rxjava3.observers

Classes in io.reactivex.rxjava3.observers that implement Observer

Modifier and Type	Class	Description
class	DefaultObserver<T>	Abstract base implementation of an Observer with support for cancelling a subscription via DefaultObserver.cancel() (synchronously) and calls DefaultObserver.onStart() when the subscription happens.
class	DisposableObserver<T>	An abstract Observer that allows asynchronous cancellation by implementing Disposable.
class	ResourceObserver<T>	An abstract Observer that allows asynchronous cancellation of its subscription and associated resources.
final class	SafeObserver<T>	Wraps another Observer and ensures all onXXX methods conform the protocol (except the requirement for serialized access).
final class	SerializedObserver<T>	Serializes access to the Observer.onNext(Object), Observer.onError(Throwable) and Observer.onComplete() methods of another Observer.
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.
(package private) static enum	TestObserver.EmptyObserver	An observer that ignores all events and does not report errors.

Fields in io.reactivex.rxjava3.observers declared as Observer

Modifier and Type	Field	Description
(package private) final Observer<? super T>	SafeObserver.downstream	The actual Subscriber.
(package private) final Observer<? super T>	SerializedObserver.downstream
private final Observer<? super T>	TestObserver.downstream	The actual observer to forward events to.

Methods in io.reactivex.rxjava3.observers with parameters of type Observer

Modifier and Type	Method	Description
static <T> @NonNull TestObserver<T>	TestObserver.create(@NonNull Observer<? super T> delegate)	Constructs a forwarding TestObserver.

Constructors in io.reactivex.rxjava3.observers with parameters of type Observer

Modifier	Constructor	Description
	SafeObserver(@NonNull Observer<? super T> downstream)	Constructs a SafeObserver by wrapping the given actual Observer.
	SerializedObserver(@NonNull Observer<? super T> downstream)	Construct a SerializedObserver by wrapping the given actual Observer.
	SerializedObserver(@NonNull Observer<? super T> actual, boolean delayError)	Construct a SerializedObserver by wrapping the given actual Observer and optionally delaying the errors till all regular values have been emitted from the internal buffer.
	TestObserver(@NonNull Observer<? super T> downstream)	Constructs a forwarding TestObserver.

Uses of Observer in io.reactivex.rxjava3.plugins

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

Modifier and Type	Field	Description
(package private) static @Nullable BiFunction<? super Observable, @NonNull ? super Observer, @NonNull ? extends Observer>	RxJavaPlugins.onObservableSubscribe
(package private) static @Nullable BiFunction<? super Observable, @NonNull ? super Observer, @NonNull ? extends Observer>	RxJavaPlugins.onObservableSubscribe

Methods in io.reactivex.rxjava3.plugins that return Observer

Modifier and Type	Method	Description
static <@NonNull T> @NonNull Observer<? super T>	RxJavaPlugins.onSubscribe(@NonNull Observable<@NonNull T> source, @NonNull Observer<? super @NonNull T> observer)	Calls the associated hook function.

Methods in io.reactivex.rxjava3.plugins that return types with arguments of type Observer

Modifier and Type	Method	Description
static @Nullable BiFunction<? super Observable, @NonNull ? super Observer, @NonNull ? extends Observer>	RxJavaPlugins.getOnObservableSubscribe()	Returns the current hook function.
static @Nullable BiFunction<? super Observable, @NonNull ? super Observer, @NonNull ? extends Observer>	RxJavaPlugins.getOnObservableSubscribe()	Returns the current hook function.

Methods in io.reactivex.rxjava3.plugins with parameters of type Observer

Modifier and Type	Method	Description
static <@NonNull T> @NonNull Observer<? super T>	RxJavaPlugins.onSubscribe(@NonNull Observable<@NonNull T> source, @NonNull Observer<? super @NonNull T> observer)	Calls the associated hook function.

Method parameters in io.reactivex.rxjava3.plugins with type arguments of type Observer

Modifier and Type	Method	Description
static void	RxJavaPlugins.setOnObservableSubscribe(@Nullable BiFunction<? super Observable, @NonNull ? super Observer, @NonNull ? extends Observer> onObservableSubscribe)	Sets the specific hook function.
static void	RxJavaPlugins.setOnObservableSubscribe(@Nullable BiFunction<? super Observable, @NonNull ? super Observer, @NonNull ? extends Observer> onObservableSubscribe)	Sets the specific hook function.

Uses of Observer in io.reactivex.rxjava3.subjects

Classes in io.reactivex.rxjava3.subjects that implement Observer

Modifier and Type	Class	Description
final class	AsyncSubject<T>	A Subject that emits the very last value followed by a completion event or the received error to Observers.
final class	BehaviorSubject<T>	Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.
final class	PublishSubject<T>	A Subject that emits (multicasts) items to currently subscribed Observers and terminal events to current or late Observers.
final class	ReplaySubject<T>	Replays events (in a configurable bounded or unbounded manner) to current and late Observers.
(package private) final class	SerializedSubject<T>	Serializes calls to the Observer methods.
class	Subject<T>	Represents an Observer and an Observable at the same time, allowing multicasting events from a single source to multiple child Observers.
final class	UnicastSubject<T>	A Subject that queues up events until a single Observer subscribes to it, replays those events to it until the Observer catches up and then switches to relaying events live to this single Observer until this UnicastSubject terminates or the Observer disposes.

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

Modifier and Type	Field	Description
(package private) final Observer<? super T>	BehaviorSubject.BehaviorDisposable.downstream
(package private) final Observer<? super T>	PublishSubject.PublishDisposable.downstream	The actual subscriber.
(package private) final Observer<? super T>	ReplaySubject.ReplayDisposable.downstream

Fields in io.reactivex.rxjava3.subjects with type parameters of type Observer

Modifier and Type	Field	Description
(package private) final AtomicReference<Observer<? super T>>	UnicastSubject.downstream	The single Observer.

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

Modifier and Type	Method	Description
(package private) void	UnicastSubject.drainFused(Observer<? super T> a)
(package private) void	UnicastSubject.drainNormal(Observer<? super T> a)
(package private) void	UnicastSubject.errorOrComplete(Observer<? super T> a)
(package private) boolean	UnicastSubject.failedFast(SimpleQueue<T> q, Observer<? super T> a)
protected void	AsyncSubject.subscribeActual(Observer<? super T> observer)
protected void	BehaviorSubject.subscribeActual(Observer<? super T> observer)
protected void	PublishSubject.subscribeActual(Observer<? super T> t)
protected void	ReplaySubject.subscribeActual(Observer<? super T> observer)
protected void	SerializedSubject.subscribeActual(Observer<? super T> observer)
protected void	UnicastSubject.subscribeActual(Observer<? super T> observer)

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

Modifier	Constructor	Description
(package private)	AsyncDisposable(Observer<? super T> actual, AsyncSubject<T> parent)
(package private)	BehaviorDisposable(Observer<? super T> actual, BehaviorSubject<T> state)
(package private)	PublishDisposable(Observer<? super T> actual, PublishSubject<T> parent)	Constructs a PublishSubscriber, wraps the actual subscriber and the state.
(package private)	ReplayDisposable(Observer<? super T> actual, ReplaySubject<T> state)