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
andCompletable
; 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 theTestObserver
that allows unit testingObservable
-,Single
-,Maybe
- andCompletable
-based flows.io.reactivex.rxjava3.plugins Contains the central plugin handlerRxJavaPlugins
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>>
EObservable. 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 Observer Modifier and Type Method Description @NonNull Observer<? super Upstream>
ObservableOperator. 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 Observer Modifier and Type Method Description @NonNull Observer<? super Upstream>
ObservableOperator. apply(@NonNull Observer<? super @NonNull Downstream> observer)
Applies a function to the childObserver
and returns a new parentObserver
.void
Observable. blockingSubscribe(@NonNull Observer<? super @NonNull T> observer)
Subscribes to the source and calls theObserver
methods on the current thread.@NonNull Observable<T>
Observable. doOnEach(@NonNull Observer<? super @NonNull T> observer)
Returns anObservable
that forwards the items and terminal events of the currentObservable
to itsObserver
s and to the given sharedObserver
instance.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).void
Observable. subscribe(@NonNull Observer<? super @NonNull T> observer)
void
ObservableSource. subscribe(@NonNull Observer<? super @NonNull T> observer)
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 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 signalsNoSuchElementException
.(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 signalsNoSuchElementException
.(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 signalsIllegalArgumentException
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 aCompositeDisposable
.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 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 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>
booleanScalarXMapZHelper. tryAsMaybe(java.lang.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>
booleanScalarXMapZHelper. tryAsSingle(java.lang.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 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
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>
booleanObservableScalarXMap. 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 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 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>
booleanQueueDrainHelper. checkTerminated(boolean d, boolean empty, Observer<?> observer, boolean delayError, SimpleQueue<?> q, Disposable disposable, ObservableQueueDrain<T,U> qd)
static <T,U>
voidQueueDrainHelper. 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 anObserver
with support for cancelling a subscription viaDefaultObserver.cancel()
(synchronously) and callsDefaultObserver.onStart()
when the subscription happens.class
DisposableObserver<T>
An abstractObserver
that allows asynchronous cancellation by implementingDisposable
.class
ResourceObserver<T>
An abstractObserver
that allows asynchronous cancellation of its subscription and associated resources.class
SafeObserver<T>
Wraps anotherObserver
and ensures allonXXX
methods conform the protocol (except the requirement for serialized access).class
SerializedObserver<T>
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 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 forwardingTestObserver
.Constructors in io.reactivex.rxjava3.observers with parameters of type Observer Constructor Description SafeObserver(@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 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 subscribedObserver
.class
PublishSubject<T>
A Subject that emits (multicasts) items to currently subscribedObserver
s and terminal events to current or lateObserver
s.class
ReplaySubject<T>
Replays events (in a configurable bounded or unbounded manner) to current and lateObserver
s.(package private) class
SerializedSubject<T>
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.class
UnicastSubject<T>
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 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)
-