Uses of Class
io.reactivex.rxjava3.internal.util.AtomicThrowable

Packages that use AtomicThrowable

Package	Description
io.reactivex.rxjava3.internal.jdk8
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.parallel
io.reactivex.rxjava3.internal.subscribers
io.reactivex.rxjava3.internal.util

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

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

Modifier and Type	Field	Description
(package private) final AtomicThrowable	FlowableFlatMapStream.FlatMapStreamSubscriber.error
(package private) final AtomicThrowable	ParallelCollector.ParallelCollectorSubscriber.error

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

Fields in io.reactivex.rxjava3.internal.operators.completable declared as AtomicThrowable

Modifier and Type	Field	Description
(package private) final AtomicThrowable	CompletableMerge.CompletableMergeSubscriber.errors
(package private) final AtomicThrowable	CompletableMergeArrayDelayError.MergeInnerCompletableObserver.errors
(package private) final AtomicThrowable	CompletableMergeArrayDelayError.TryTerminateAndReportDisposable.errors

Constructors in io.reactivex.rxjava3.internal.operators.completable with parameters of type AtomicThrowable

Modifier	Constructor	Description
(package private)	MergeInnerCompletableObserver(CompletableObserver observer, CompositeDisposable set, AtomicThrowable error, AtomicInteger wip)
(package private)	TryTerminateAndReportDisposable(AtomicThrowable errors)

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

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as AtomicThrowable

Modifier and Type	Field	Description
(package private) final AtomicThrowable	FlowableCombineLatest.CombineLatestCoordinator.error
(package private) final AtomicThrowable	FlowableSkipUntil.SkipUntilMainSubscriber.error
(package private) final AtomicThrowable	FlowableTakeUntil.TakeUntilMainSubscriber.error
(package private) final AtomicThrowable	FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.error
(package private) final AtomicThrowable	FlowableWithLatestFromMany.WithLatestFromSubscriber.error
(package private) final AtomicThrowable	FlowableBufferBoundary.BufferBoundarySubscriber.errors
(package private) final AtomicThrowable	FlowableConcatMap.BaseConcatMapSubscriber.errors
(package private) final AtomicThrowable	FlowableConcatMapEager.ConcatMapEagerDelayErrorSubscriber.errors
(package private) final AtomicThrowable	FlowableConcatMapScheduler.BaseConcatMapSubscriber.errors
(package private) final AtomicThrowable	FlowableCreate.SerializedEmitter.errors
(package private) final AtomicThrowable	FlowableFlatMap.MergeSubscriber.errors
(package private) final AtomicThrowable	FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber.errors
(package private) final AtomicThrowable	FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber.errors
(package private) final AtomicThrowable	FlowableFlatMapMaybe.FlatMapMaybeSubscriber.errors
(package private) final AtomicThrowable	FlowableFlatMapSingle.FlatMapSingleSubscriber.errors
(package private) final AtomicThrowable	FlowableMergeWithCompletable.MergeWithSubscriber.errors
(package private) final AtomicThrowable	FlowableMergeWithMaybe.MergeWithObserver.errors
(package private) final AtomicThrowable	FlowableMergeWithSingle.MergeWithObserver.errors
(package private) final AtomicThrowable	FlowableSequenceEqual.EqualCoordinator.errors
(package private) final AtomicThrowable	FlowableSequenceEqualSingle.EqualCoordinator.errors
(package private) final AtomicThrowable	FlowableSwitchMap.SwitchMapSubscriber.errors
(package private) final AtomicThrowable	FlowableWindowBoundary.WindowBoundaryMainSubscriber.errors
(package private) final AtomicThrowable	FlowableZip.ZipCoordinator.errors

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

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

Modifier and Type	Field	Description
(package private) final AtomicThrowable	MaybeConcatArrayDelayError.ConcatMaybeObserver.errors
(package private) final AtomicThrowable	MaybeMergeArray.MergeMaybeObserver.errors

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

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

Modifier and Type	Field	Description
(package private) final AtomicThrowable	ConcatMapXMainObserver.errors
(package private) final AtomicThrowable	ConcatMapXMainSubscriber.errors
(package private) final AtomicThrowable	FlowableSwitchMapCompletable.SwitchMapCompletableObserver.errors
(package private) final AtomicThrowable	FlowableSwitchMapMaybe.SwitchMapMaybeSubscriber.errors
(package private) final AtomicThrowable	FlowableSwitchMapSingle.SwitchMapSingleSubscriber.errors
(package private) final AtomicThrowable	ObservableSwitchMapCompletable.SwitchMapCompletableObserver.errors
(package private) final AtomicThrowable	ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver.errors
(package private) final AtomicThrowable	ObservableSwitchMapSingle.SwitchMapSingleMainObserver.errors

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

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

Modifier and Type	Field	Description
(package private) final AtomicThrowable	ObservableRepeatWhen.RepeatWhenObserver.error
(package private) final AtomicThrowable	ObservableRetryWhen.RepeatWhenObserver.error
(package private) final AtomicThrowable	ObservableTakeUntil.TakeUntilMainObserver.error
(package private) final AtomicThrowable	ObservableWindowBoundarySelector.WindowBoundaryMainObserver.error
(package private) final AtomicThrowable	ObservableWithLatestFromMany.WithLatestFromObserver.error
(package private) final AtomicThrowable	ObservableBufferBoundary.BufferBoundaryObserver.errors
(package private) final AtomicThrowable	ObservableCombineLatest.LatestCoordinator.errors
(package private) final AtomicThrowable	ObservableConcatMap.ConcatMapDelayErrorObserver.errors
(package private) final AtomicThrowable	ObservableConcatMapEager.ConcatMapEagerMainObserver.errors
(package private) final AtomicThrowable	ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.errors
(package private) final AtomicThrowable	ObservableCreate.SerializedEmitter.errors
(package private) final AtomicThrowable	ObservableFlatMap.MergeObserver.errors
(package private) final AtomicThrowable	ObservableFlatMapCompletable.FlatMapCompletableMainObserver.errors
(package private) final AtomicThrowable	ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver.errors
(package private) final AtomicThrowable	ObservableFlatMapMaybe.FlatMapMaybeObserver.errors
(package private) final AtomicThrowable	ObservableFlatMapSingle.FlatMapSingleObserver.errors
(package private) final AtomicThrowable	ObservableMergeWithCompletable.MergeWithObserver.errors
(package private) final AtomicThrowable	ObservableMergeWithMaybe.MergeWithObserver.errors
(package private) final AtomicThrowable	ObservableMergeWithSingle.MergeWithObserver.errors
(package private) final AtomicThrowable	ObservableSwitchMap.SwitchMapObserver.errors
(package private) final AtomicThrowable	ObservableWindowBoundary.WindowBoundaryMainObserver.errors

Uses of AtomicThrowable in io.reactivex.rxjava3.internal.operators.parallel

Fields in io.reactivex.rxjava3.internal.operators.parallel declared as AtomicThrowable

Modifier and Type	Field	Description
(package private) final AtomicThrowable	ParallelReduceFull.ParallelReduceFullMainSubscriber.error
(package private) final AtomicThrowable	ParallelJoin.JoinSubscriptionBase.errors

Uses of AtomicThrowable in io.reactivex.rxjava3.internal.subscribers

Fields in io.reactivex.rxjava3.internal.subscribers declared as AtomicThrowable

Modifier and Type	Field	Description
(package private) final AtomicThrowable	StrictSubscriber.error

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

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

Modifier and Type	Method	Description
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.onComplete(org.reactivestreams.Subscriber<?> subscriber, 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 void	HalfSerializer.onError(org.reactivestreams.Subscriber<?> subscriber, 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.
static <T> boolean	HalfSerializer.onNext(org.reactivestreams.Subscriber<? super T> subscriber, 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.