Uses of Interface
io.reactivex.rxjava3.core.Observer
Packages that use Observer
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.Default wrappers and implementations for observer-based consumer classes and interfaces,
including disposable and resource-tracking variants and
the
TestObserver
that allows unit testing
Observable
-, Single
-,
Maybe
- and Completable
-based flows.Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.Classes representing so-called hot sources, aka subjects, that implement a base reactive class and
the respective consumer type at once to allow forms of multicasting events to multiple
consumers as well as consuming another base reactive type of their kind.
-
Uses of Observer in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with type parameters of type ObserverModifier and TypeMethodDescriptionObservable.subscribeWith
(@NonNull E observer) Subscribes a givenObserver
(subclass) to the currentObservable
and returns the givenObserver
instance as is.Methods in io.reactivex.rxjava3.core that return ObserverModifier and TypeMethodDescriptionObservableOperator.apply
(@NonNull Observer<? super @NonNull Downstream> observer) Applies a function to the childObserver
and returns a new parentObserver
.Methods in io.reactivex.rxjava3.core with parameters of type ObserverModifier and TypeMethodDescriptionObservableOperator.apply
(@NonNull Observer<? super @NonNull Downstream> observer) Applies a function to the childObserver
and returns a new parentObserver
.final void
Observable.blockingSubscribe
(@NonNull Observer<? super @NonNull T> observer) Subscribes to the source and calls theObserver
methods on the current thread.final @NonNull Observable
<T> Returns anObservable
that forwards the items and terminal events of the currentObservable
to itsObserver
s and to the given sharedObserver
instance.final void
Observable.safeSubscribe
(@NonNull Observer<? super @NonNull T> observer) Subscribes to the currentObservable
and wraps the givenObserver
into aSafeObserver
(if not already aSafeObserver
) that deals with exceptions thrown by a misbehavingObserver
(that doesn't follow the Reactive Streams specification).final void
void
Subscribes the givenObserver
to thisObservableSource
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 incomingObserver
s. -
Uses of Observer in io.reactivex.rxjava3.internal.disposables
Methods in io.reactivex.rxjava3.internal.disposables with parameters of type Observer -
Uses of Observer in io.reactivex.rxjava3.internal.jdk8
Classes in io.reactivex.rxjava3.internal.jdk8 that implement ObserverModifier and TypeClassDescription(package private) static final class
(package private) static final class
final class
Signals the first element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signalsNoSuchElementException
.(package private) static final class
final class
Signals the last element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signalsNoSuchElementException
.(package private) static final class
final class
Signals the only element of the source via the underlying CompletableFuture, signals the a default item if the upstream is empty or signalsIllegalArgumentException
if the upstream has more than one item.(package private) class
Base class that extends CompletableFuture and provides basic infrastructure to notify watchers upon upstream signals.Fields in io.reactivex.rxjava3.internal.jdk8 declared as ObserverModifier and TypeFieldDescriptionMaybeFlattenStreamAsObservable.FlattenStreamMultiObserver.downstream
ObservableFlatMapStream.FlatMapStreamObserver.downstream
ObservableFromStream.StreamDisposable.downstream
Methods in io.reactivex.rxjava3.internal.jdk8 with parameters of type ObserverModifier and TypeMethodDescriptionprotected 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 ObserverModifierConstructorDescription(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 ObserverModifier and TypeClassDescriptionclass
Base class for a fuseable intermediate observer.class
final class
Blocks until the upstream signals its first value or completes.final class
Blocks until the upstream signals its last value or completes.final class
class
A fuseable Observer that can generate 0 or 1 resulting value.final class
Wraps lambda callbacks and when the upstream terminates or this observer gets disposed, removes itself from aCompositeDisposable
.final class
final class
final class
An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.final class
Subscriber that can fuse with the upstream and calls a support interface whenever an event is available.final class
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 ObserverModifier and TypeFieldDescriptionBasicFuseableObserver.downstream
The downstream subscriber.DeferredScalarDisposable.downstream
The target of the events.DisposableLambdaObserver.downstream
QueueDrainObserver.downstream
Methods in io.reactivex.rxjava3.internal.observers with parameters of type ObserverConstructors in io.reactivex.rxjava3.internal.observers with parameters of type ObserverModifierConstructorDescriptionBasicFuseableObserver
(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 ObserverModifier and TypeClassDescription(package private) static final class
Methods in io.reactivex.rxjava3.internal.operators.completable with parameters of type ObserverModifier and TypeMethodDescriptionprotected 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 ObserverModifier and TypeClassDescription(package private) static final class
-
Uses of Observer in io.reactivex.rxjava3.internal.operators.maybe
Fields in io.reactivex.rxjava3.internal.operators.maybe declared as ObserverModifier and TypeFieldDescriptionMaybeFlatMapIterableObservable.FlatMapIterableObserver.downstream
Methods in io.reactivex.rxjava3.internal.operators.maybe with parameters of type ObserverModifier and TypeMethodDescriptionstatic <T> MaybeObserver
<T> Creates aMaybeObserver
wrapper around aObserver
.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 ObserverModifierConstructorDescription(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 ObserverModifier and TypeClassDescription(package private) static final class
class
Base class for implementing concatMapX main observers.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.mixed declared as ObserverModifier and TypeFieldDescriptionCompletableAndThenObservable.AndThenObservableObserver.downstream
MaybeFlatMapObservable.FlatMapObserver.downstream
ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.downstream
ObservableConcatMapSingle.ConcatMapSingleMainObserver.downstream
ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver.downstream
ObservableSwitchMapSingle.SwitchMapSingleMainObserver.downstream
SingleFlatMapObservable.FlatMapObserver.downstream
Methods in io.reactivex.rxjava3.internal.operators.mixed with parameters of type ObserverModifier and TypeMethodDescriptionprotected 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 aMaybeSource
mapped from a scalar source (which implementsSupplier
).(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 aSingleSource
mapped from a scalar source (which implementsSupplier
).Constructors in io.reactivex.rxjava3.internal.operators.mixed with parameters of type ObserverModifierConstructorDescription(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 ObserverModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
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
(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
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
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(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
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
final class
Fields in io.reactivex.rxjava3.internal.operators.observable declared as ObserverModifier and TypeFieldDescriptionObservableDelaySubscriptionOther.DelayObserver.child
ObservableReplay.InnerDisposable.child
The actual child subscriber.ObservableAll.AllObserver.downstream
ObservableAmb.AmbCoordinator.downstream
ObservableAmb.AmbInnerObserver.downstream
ObservableAny.AnyObserver.downstream
ObservableBuffer.BufferExactObserver.downstream
ObservableBuffer.BufferSkipObserver.downstream
ObservableBufferBoundary.BufferBoundaryObserver.downstream
ObservableCache.CacheDisposable.downstream
ObservableCollect.CollectObserver.downstream
ObservableCombineLatest.LatestCoordinator.downstream
ObservableConcatMap.ConcatMapDelayErrorObserver.DelayErrorInnerObserver.downstream
ObservableConcatMap.ConcatMapDelayErrorObserver.downstream
ObservableConcatMap.SourceObserver.downstream
ObservableConcatMap.SourceObserver.InnerObserver.downstream
ObservableConcatMapEager.ConcatMapEagerMainObserver.downstream
ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.DelayErrorInnerObserver.downstream
ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.downstream
ObservableConcatMapScheduler.ConcatMapObserver.downstream
ObservableConcatMapScheduler.ConcatMapObserver.InnerObserver.downstream
ObservableConcatWithCompletable.ConcatWithObserver.downstream
ObservableConcatWithMaybe.ConcatWithObserver.downstream
ObservableConcatWithSingle.ConcatWithObserver.downstream
ObservableCount.CountObserver.downstream
ObservableDebounce.DebounceObserver.downstream
ObservableDebounceTimed.DebounceTimedObserver.downstream
ObservableDelay.DelayObserver.downstream
ObservableDematerialize.DematerializeObserver.downstream
ObservableDetach.DetachObserver.downstream
ObservableDoFinally.DoFinallyObserver.downstream
ObservableDoOnEach.DoOnEachObserver.downstream
ObservableElementAt.ElementAtObserver.downstream
ObservableFlatMap.MergeObserver.downstream
ObservableFlatMapCompletable.FlatMapCompletableMainObserver.downstream
ObservableFlatMapMaybe.FlatMapMaybeObserver.downstream
ObservableFlatMapSingle.FlatMapSingleObserver.downstream
ObservableFlattenIterable.FlattenIterableObserver.downstream
ObservableFromArray.FromArrayDisposable.downstream
ObservableFromCompletable.FromCompletableObserver.downstream
ObservableFromIterable.FromIterableDisposable.downstream
ObservableFromPublisher.PublisherSubscriber.downstream
ObservableGenerate.GeneratorDisposable.downstream
(package private) final Observer
<? super GroupedObservable<K, V>> ObservableGroupBy.GroupByObserver.downstream
ObservableGroupJoin.GroupJoinDisposable.downstream
ObservableHide.HideDisposable.downstream
ObservableIgnoreElements.IgnoreObservable.downstream
ObservableInterval.IntervalObserver.downstream
ObservableIntervalRange.IntervalRangeObserver.downstream
ObservableJoin.JoinDisposable.downstream
(package private) final Observer
<? super ObservableSource<? extends R>> ObservableMapNotification.MapNotificationObserver.downstream
(package private) final Observer
<? super Notification<T>> ObservableMaterialize.MaterializeObserver.downstream
ObservableMergeWithCompletable.MergeWithObserver.downstream
ObservableMergeWithMaybe.MergeWithObserver.downstream
ObservableMergeWithSingle.MergeWithObserver.downstream
ObservableObserveOn.ObserveOnObserver.downstream
ObservableOnErrorComplete.OnErrorCompleteObserver.downstream
ObservableOnErrorNext.OnErrorNextObserver.downstream
ObservableOnErrorReturn.OnErrorReturnObserver.downstream
ObservablePublish.InnerDisposable.downstream
ObservablePublishSelector.TargetObserver.downstream
ObservableRange.RangeDisposable.downstream
ObservableRangeLong.RangeDisposable.downstream
ObservableRefCount.RefCountObserver.downstream
ObservableRepeat.RepeatObserver.downstream
ObservableRepeatUntil.RepeatUntilObserver.downstream
ObservableRepeatWhen.RepeatWhenObserver.downstream
ObservableRetryBiPredicate.RetryBiObserver.downstream
ObservableRetryPredicate.RepeatObserver.downstream
ObservableRetryWhen.RepeatWhenObserver.downstream
ObservableSampleTimed.SampleTimedObserver.downstream
ObservableSampleWithObservable.SampleMainObserver.downstream
ObservableScan.ScanObserver.downstream
ObservableScanSeed.ScanSeedObserver.downstream
ObservableSequenceEqual.EqualCoordinator.downstream
ObservableSkip.SkipObserver.downstream
ObservableSkipLast.SkipLastObserver.downstream
ObservableSkipLastTimed.SkipLastTimedObserver.downstream
ObservableSkipUntil.SkipUntilObserver.downstream
ObservableSkipWhile.SkipWhileObserver.downstream
ObservableSubscribeOn.SubscribeOnObserver.downstream
ObservableSwitchIfEmpty.SwitchIfEmptyObserver.downstream
ObservableSwitchMap.SwitchMapObserver.downstream
ObservableTake.TakeObserver.downstream
ObservableTakeLast.TakeLastObserver.downstream
ObservableTakeLastOne.TakeLastOneObserver.downstream
ObservableTakeLastTimed.TakeLastTimedObserver.downstream
ObservableTakeUntil.TakeUntilMainObserver.downstream
ObservableTakeUntilPredicate.TakeUntilPredicateObserver.downstream
ObservableTakeWhile.TakeWhileObserver.downstream
ObservableThrottleFirstTimed.DebounceTimedObserver.downstream
ObservableThrottleLatest.ThrottleLatestObserver.downstream
ObservableTimeInterval.TimeIntervalObserver.downstream
ObservableTimeout.TimeoutFallbackObserver.downstream
ObservableTimeout.TimeoutObserver.downstream
ObservableTimeoutTimed.FallbackObserver.downstream
ObservableTimeoutTimed.TimeoutFallbackObserver.downstream
ObservableTimeoutTimed.TimeoutObserver.downstream
ObservableTimer.TimerObserver.downstream
ObservableToList.ToListObserver.downstream
ObservableUnsubscribeOn.UnsubscribeObserver.downstream
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
ObservableWithLatestFrom.WithLatestFromObserver.downstream
ObservableWithLatestFromMany.WithLatestFromObserver.downstream
ObservableZip.ZipCoordinator.downstream
ObservableZipIterable.ZipIterableObserver.downstream
ObserverResourceWrapper.downstream
ObservableCreate.CreateEmitter.observer
ObservableInternalHelper.ObserverOnComplete.observer
ObservableInternalHelper.ObserverOnError.observer
ObservableInternalHelper.ObserverOnNext.observer
ObservableScalarXMap.ScalarDisposable.observer
Fields in io.reactivex.rxjava3.internal.operators.observable with type parameters of type ObserverModifier and TypeFieldDescription(package private) final AtomicReference
<Observer<? super T>> ObservableGroupBy.State.actual
Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type ObserverModifier and TypeMethodDescriptionvoid
void
void
void
(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
(package private) void
(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) 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
void
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 ObserverModifierConstructorDescription(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)
(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)
(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)
(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)
(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 ObserverModifier and TypeClassDescription(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.single declared as ObserverModifier and TypeFieldDescriptionSingleFlatMapIterableObservable.FlatMapIterableObserver.downstream
Methods in io.reactivex.rxjava3.internal.operators.single with parameters of type ObserverModifier and TypeMethodDescriptionstatic <T> SingleObserver
<T> Creates aSingleObserver
wrapper around aObserver
.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 ObserverModifierConstructorDescription(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 ObserverModifier and TypeClassDescriptionenum
Singleton implementing many interfaces as empty.Methods in io.reactivex.rxjava3.internal.util that return ObserverMethods in io.reactivex.rxjava3.internal.util with parameters of type ObserverModifier and TypeMethodDescription<U> boolean
Interprets the contents as NotificationLite objects and calls the appropriate Observer method.static <T> boolean
Calls the appropriate Observer method based on the type of the notification.void
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 ObserverModifier and TypeClassDescriptionclass
Abstract base implementation of anObserver
with support for cancelling a subscription viaDefaultObserver.cancel()
(synchronously) and callsDefaultObserver.onStart()
when the subscription happens.class
An abstractObserver
that allows asynchronous cancellation by implementingDisposable
.class
An abstractObserver
that allows asynchronous cancellation of its subscription and associated resources.final class
SafeObserver<T>
Wraps anotherObserver
and ensures allonXXX
methods conform the protocol (except the requirement for serialized access).final class
Serializes access to theonNext(Object)
,onError(Throwable)
andonComplete()
methods of anotherObserver
.class
TestObserver<T>
AnObserver
,MaybeObserver
,SingleObserver
andCompletableObserver
composite that can record events fromObservable
s,Maybe
s,Single
s andCompletable
s and allows making assertions about them.(package private) static enum
An observer that ignores all events and does not report errors.Fields in io.reactivex.rxjava3.observers declared as ObserverModifier and TypeFieldDescriptionSafeObserver.downstream
The actual Subscriber.SerializedObserver.downstream
TestObserver.downstream
The actual observer to forward events to.Methods in io.reactivex.rxjava3.observers with parameters of type ObserverModifier and TypeMethodDescriptionstatic <T> @NonNull TestObserver
<T> Constructs a forwardingTestObserver
.Constructors in io.reactivex.rxjava3.observers with parameters of type ObserverModifierConstructorDescriptionSafeObserver
(@NonNull Observer<? super T> downstream) Constructs aSafeObserver
by wrapping the given actualObserver
.SerializedObserver
(@NonNull Observer<? super T> downstream) Construct aSerializedObserver
by wrapping the given actualObserver
.SerializedObserver
(@NonNull Observer<? super T> actual, boolean delayError) Construct a SerializedObserver by wrapping the given actualObserver
and optionally delaying the errors till all regular values have been emitted from the internal buffer.TestObserver
(@NonNull Observer<? super T> downstream) Constructs a forwardingTestObserver
. -
Uses of Observer in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins with type parameters of type ObserverModifier and TypeFieldDescription(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 ObserverModifier and TypeMethodDescriptionRxJavaPlugins.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 ObserverModifier and TypeMethodDescriptionstatic @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 ObserverModifier and TypeMethodDescriptionRxJavaPlugins.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 ObserverModifier and TypeMethodDescriptionstatic 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 ObserverModifier and TypeClassDescriptionfinal class
AsyncSubject<T>
A Subject that emits the very last value followed by a completion event or the received error to Observers.final class
Subject that emits the most recent item it has observed and all subsequent observed items to each subscribedObserver
.final class
A Subject that emits (multicasts) items to currently subscribedObserver
s and terminal events to current or lateObserver
s.final class
Replays events (in a configurable bounded or unbounded manner) to current and lateObserver
s.(package private) final class
Serializes calls to the Observer methods.class
Subject<T>
Represents anObserver
and anObservable
at the same time, allowing multicasting events from a single source to multiple childObserver
s.final class
A Subject that queues up events until a singleObserver
subscribes to it, replays those events to it until theObserver
catches up and then switches to relaying events live to this singleObserver
until thisUnicastSubject
terminates or theObserver
disposes.Fields in io.reactivex.rxjava3.subjects declared as ObserverModifier and TypeFieldDescriptionBehaviorSubject.BehaviorDisposable.downstream
PublishSubject.PublishDisposable.downstream
The actual subscriber.ReplaySubject.ReplayDisposable.downstream
Fields in io.reactivex.rxjava3.subjects with type parameters of type ObserverModifier and TypeFieldDescription(package private) final AtomicReference
<Observer<? super T>> UnicastSubject.downstream
The single Observer.Methods in io.reactivex.rxjava3.subjects with parameters of type ObserverModifier and TypeMethodDescription(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 ObserverModifierConstructorDescription(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)