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) AtomicThrowable	FlowableFlatMapStream.FlatMapStreamSubscriber.error
(package private) 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) AtomicThrowable	CompletableMerge.CompletableMergeSubscriber.errors
(package private) AtomicThrowable	CompletableMergeArrayDelayError.MergeInnerCompletableObserver.errors
(package private) AtomicThrowable	CompletableMergeArrayDelayError.TryTerminateAndReportDisposable.errors

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

Constructor	Description
MergeInnerCompletableObserver(CompletableObserver observer, CompositeDisposable set, AtomicThrowable error, java.util.concurrent.atomic.AtomicInteger wip)
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) AtomicThrowable	FlowableCombineLatest.CombineLatestCoordinator.error
(package private) AtomicThrowable	FlowableSkipUntil.SkipUntilMainSubscriber.error
(package private) AtomicThrowable	FlowableTakeUntil.TakeUntilMainSubscriber.error
(package private) AtomicThrowable	FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.error
(package private) AtomicThrowable	FlowableWithLatestFromMany.WithLatestFromSubscriber.error
(package private) AtomicThrowable	FlowableBufferBoundary.BufferBoundarySubscriber.errors
(package private) AtomicThrowable	FlowableConcatMap.BaseConcatMapSubscriber.errors
(package private) AtomicThrowable	FlowableConcatMapEager.ConcatMapEagerDelayErrorSubscriber.errors
(package private) AtomicThrowable	FlowableConcatMapScheduler.BaseConcatMapSubscriber.errors
(package private) AtomicThrowable	FlowableCreate.SerializedEmitter.errors
(package private) AtomicThrowable	FlowableFlatMap.MergeSubscriber.errors
(package private) AtomicThrowable	FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber.errors
(package private) AtomicThrowable	FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber.errors
(package private) AtomicThrowable	FlowableFlatMapMaybe.FlatMapMaybeSubscriber.errors
(package private) AtomicThrowable	FlowableFlatMapSingle.FlatMapSingleSubscriber.errors
(package private) AtomicThrowable	FlowableMergeWithCompletable.MergeWithSubscriber.errors
(package private) AtomicThrowable	FlowableMergeWithMaybe.MergeWithObserver.errors
(package private) AtomicThrowable	FlowableMergeWithSingle.MergeWithObserver.errors
(package private) AtomicThrowable	FlowableSequenceEqual.EqualCoordinator.errors
(package private) AtomicThrowable	FlowableSequenceEqualSingle.EqualCoordinator.errors
(package private) AtomicThrowable	FlowableSwitchMap.SwitchMapSubscriber.errors
(package private) AtomicThrowable	FlowableWindowBoundary.WindowBoundaryMainSubscriber.errors
(package private) 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) AtomicThrowable	MaybeConcatArrayDelayError.ConcatMaybeObserver.errors
(package private) 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) AtomicThrowable	ConcatMapXMainObserver.errors
(package private) AtomicThrowable	ConcatMapXMainSubscriber.errors
(package private) AtomicThrowable	FlowableSwitchMapCompletable.SwitchMapCompletableObserver.errors
(package private) AtomicThrowable	FlowableSwitchMapMaybe.SwitchMapMaybeSubscriber.errors
(package private) AtomicThrowable	FlowableSwitchMapSingle.SwitchMapSingleSubscriber.errors
(package private) AtomicThrowable	ObservableSwitchMapCompletable.SwitchMapCompletableObserver.errors
(package private) AtomicThrowable	ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver.errors
(package private) 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) AtomicThrowable	ObservableRepeatWhen.RepeatWhenObserver.error
(package private) AtomicThrowable	ObservableRetryWhen.RepeatWhenObserver.error
(package private) AtomicThrowable	ObservableTakeUntil.TakeUntilMainObserver.error
(package private) AtomicThrowable	ObservableWindowBoundarySelector.WindowBoundaryMainObserver.error
(package private) AtomicThrowable	ObservableWithLatestFromMany.WithLatestFromObserver.error
(package private) AtomicThrowable	ObservableBufferBoundary.BufferBoundaryObserver.errors
(package private) AtomicThrowable	ObservableCombineLatest.LatestCoordinator.errors
(package private) AtomicThrowable	ObservableConcatMap.ConcatMapDelayErrorObserver.errors
(package private) AtomicThrowable	ObservableConcatMapEager.ConcatMapEagerMainObserver.errors
(package private) AtomicThrowable	ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.errors
(package private) AtomicThrowable	ObservableCreate.SerializedEmitter.errors
(package private) AtomicThrowable	ObservableFlatMap.MergeObserver.errors
(package private) AtomicThrowable	ObservableFlatMapCompletable.FlatMapCompletableMainObserver.errors
(package private) AtomicThrowable	ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver.errors
(package private) AtomicThrowable	ObservableFlatMapMaybe.FlatMapMaybeObserver.errors
(package private) AtomicThrowable	ObservableFlatMapSingle.FlatMapSingleObserver.errors
(package private) AtomicThrowable	ObservableMergeWithCompletable.MergeWithObserver.errors
(package private) AtomicThrowable	ObservableMergeWithMaybe.MergeWithObserver.errors
(package private) AtomicThrowable	ObservableMergeWithSingle.MergeWithObserver.errors
(package private) AtomicThrowable	ObservableSwitchMap.SwitchMapObserver.errors
(package private) 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) AtomicThrowable	ParallelReduceFull.ParallelReduceFullMainSubscriber.error
(package private) 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) 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, 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.onComplete(org.reactivestreams.Subscriber<?> subscriber, 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 void	HalfSerializer.onError(org.reactivestreams.Subscriber<?> subscriber, 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.
static <T> boolean	HalfSerializer.onNext(org.reactivestreams.Subscriber<? super T> subscriber, 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.