Uses of Class
io.reactivex.rxjava3.internal.util.AtomicThrowable
Packages that use AtomicThrowable
Package
Description
-
Uses of AtomicThrowable in io.reactivex.rxjava3.internal.jdk8
Fields in io.reactivex.rxjava3.internal.jdk8 declared as AtomicThrowableModifier and TypeFieldDescription(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 AtomicThrowableModifier and TypeFieldDescription(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 AtomicThrowableModifierConstructorDescription(package private)
MergeInnerCompletableObserver
(CompletableObserver observer, CompositeDisposable set, AtomicThrowable error, AtomicInteger wip) (package private)
-
Uses of AtomicThrowable in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as AtomicThrowableModifier and TypeFieldDescription(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 AtomicThrowableModifier and TypeFieldDescription(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 AtomicThrowableModifier and TypeFieldDescription(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 AtomicThrowableModifier and TypeFieldDescription(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 AtomicThrowableModifier and TypeFieldDescription(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 -
Uses of AtomicThrowable in io.reactivex.rxjava3.internal.util
Methods in io.reactivex.rxjava3.internal.util with parameters of type AtomicThrowableModifier and TypeMethodDescriptionstatic 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.