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
<@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.
void	Observable.blockingSubscribe(@NonNull Observer<? super @NonNull T> observer)	Subscribes to the source and calls the Observer methods on the current thread.
@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.
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).
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(java.lang.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 class	ObservableCollectWithCollector.CollectorObserver<T,A,R>
(package private) static class	ObservableCollectWithCollectorSingle.CollectorSingleObserver<T,A,R>
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 class	ObservableFlatMapStream.FlatMapStreamObserver<T,R>
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 class	ObservableMapOptional.MapOptionalObserver<T,R>
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) Observer<? super R>	MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver.downstream
(package private) Observer<? super R>	ObservableFlatMapStream.FlatMapStreamObserver.downstream
(package private) 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, java.util.stream.Stream<T> stream)	Subscribes to the Stream.

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

Constructor	Description
CollectorObserver(Observer<? super R> downstream, A container, java.util.function.BiConsumer<A,T> accumulator, java.util.function.Function<A,R> finisher)
CompletionStageHandler(Observer<? super T> downstream, ObservableFromCompletionStage.BiConsumerAtomicReference<T> whenReference)
FlatMapStreamObserver(Observer<? super R> downstream, Function<? super T,? extends java.util.stream.Stream<? extends R>> mapper)
FlattenStreamMultiObserver(Observer<? super R> downstream, Function<? super T,? extends java.util.stream.Stream<? extends R>> mapper)
MapOptionalObserver(Observer<? super R> downstream, Function<? super T,java.util.Optional<? extends R>> mapper)
StreamDisposable(Observer<? super T> downstream, java.util.Iterator<T> iterator, java.lang.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>
class	BlockingFirstObserver<T>	Blocks until the upstream signals its first value or completes.
class	BlockingLastObserver<T>	Blocks until the upstream signals its last value or completes.
class	BlockingObserver<T>
class	DeferredScalarObserver<T,R>	A fuseable Observer that can generate 0 or 1 resulting value.
class	DisposableAutoReleaseObserver<T>	Wraps lambda callbacks and when the upstream terminates or this observer gets disposed, removes itself from a CompositeDisposable.
class	DisposableLambdaObserver<T>
class	ForEachWhileObserver<T>
class	FutureObserver<T>	An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.
class	InnerQueuedObserver<T>	Subscriber that can fuse with the upstream and calls a support interface whenever an event is available.
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 Observer<? super R>	BasicFuseableObserver.downstream	The downstream subscriber.
protected Observer<? super T>	DeferredScalarDisposable.downstream	The target of the events.
(package private) Observer<? super T>	DisposableLambdaObserver.downstream
protected 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

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

Constructor	Description
FlatMapIterableObserver(Observer<? super R> actual, Function<? super T,? extends java.lang.Iterable<? extends R>> mapper)
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 class	CompletableAndThenObservable.AndThenObservableObserver<R>
class	ConcatMapXMainObserver<T>	Base class for implementing concatMapX main observers.
(package private) static class	MaybeFlatMapObservable.FlatMapObserver<T,R>
(package private) static class	ObservableConcatMapCompletable.ConcatMapCompletableObserver<T>
(package private) static class	ObservableConcatMapMaybe.ConcatMapMaybeMainObserver<T,R>
(package private) static class	ObservableConcatMapSingle.ConcatMapSingleMainObserver<T,R>
(package private) static class	ObservableSwitchMapCompletable.SwitchMapCompletableObserver<T>
(package private) static class	ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver<T,R>
(package private) static class	ObservableSwitchMapSingle.SwitchMapSingleMainObserver<T,R>
(package private) static class	SingleFlatMapObservable.FlatMapObserver<T,R>

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

Modifier and Type	Field	Description
(package private) Observer<? super R>	CompletableAndThenObservable.AndThenObservableObserver.downstream
(package private) Observer<? super R>	MaybeFlatMapObservable.FlatMapObserver.downstream
(package private) Observer<? super R>	ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.downstream
(package private) Observer<? super R>	ObservableConcatMapSingle.ConcatMapSingleMainObserver.downstream
(package private) Observer<? super R>	ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver.downstream
(package private) Observer<? super R>	ObservableSwitchMapSingle.SwitchMapSingleMainObserver.downstream
(package private) 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(java.lang.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(java.lang.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

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

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

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

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

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

Modifier and Type	Field	Description
(package private) 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

Constructor	Description
FlatMapIterableObserver(Observer<? super R> actual, Function<? super T,? extends java.lang.Iterable<? extends R>> mapper)
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
class	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(java.lang.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(java.lang.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, java.util.concurrent.atomic.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, java.lang.Throwable ex, java.util.concurrent.atomic.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, java.util.concurrent.atomic.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.
class	SafeObserver<T>	Wraps another Observer and ensures all onXXX methods conform the protocol (except the requirement for serialized access).
class	SerializedObserver<T>	Serializes access to the onNext(Object), onError(Throwable) and 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 class	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) Observer<? super T>	SafeObserver.downstream	The actual Subscriber.
(package private) Observer<? super T>	SerializedObserver.downstream
private 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

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,? super Observer,? extends Observer>	RxJavaPlugins.onObservableSubscribe
(package private) static @Nullable BiFunction<? super Observable,? super Observer,? 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,? super Observer,? extends Observer>	RxJavaPlugins.getOnObservableSubscribe()	Returns the current hook function.
static @Nullable BiFunction<? super Observable,? super Observer,? 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,? super Observer,? extends Observer> onObservableSubscribe)	Sets the specific hook function.
static void	RxJavaPlugins.setOnObservableSubscribe(@Nullable BiFunction<? super Observable,? super Observer,? 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
class	AsyncSubject<T>	A Subject that emits the very last value followed by a completion event or the received error to Observers.
class	BehaviorSubject<T>	Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.
class	PublishSubject<T>	A Subject that emits (multicasts) items to currently subscribed Observers and terminal events to current or late Observers.
class	ReplaySubject<T>	Replays events (in a configurable bounded or unbounded manner) to current and late Observers.
(package private) 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.
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) Observer<? super T>	BehaviorSubject.BehaviorDisposable.downstream
(package private) Observer<? super T>	PublishSubject.PublishDisposable.downstream	The actual subscriber.
(package private) 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) java.util.concurrent.atomic.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

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