Uses of Class
io.reactivex.rxjava3.internal.util.AtomicThrowable
-
-
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.
-