Class FlowableRetryWhen.RetryWhenSubscriber<T>
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicInteger
-
- io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter
-
- io.reactivex.rxjava3.internal.operators.flowable.FlowableRepeatWhen.WhenSourceSubscriber<T,java.lang.Throwable>
-
- io.reactivex.rxjava3.internal.operators.flowable.FlowableRetryWhen.RetryWhenSubscriber<T>
-
- All Implemented Interfaces:
FlowableSubscriber<T>
,java.io.Serializable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
- FlowableRetryWhen<T>
static final class FlowableRetryWhen.RetryWhenSubscriber<T> extends FlowableRepeatWhen.WhenSourceSubscriber<T,java.lang.Throwable>
-
-
Field Summary
Fields Modifier and Type Field Description private static long
serialVersionUID
-
Fields inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableRepeatWhen.WhenSourceSubscriber
downstream, processor, receiver
-
Fields inherited from class io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter
unbounded
-
-
Constructor Summary
Constructors Constructor Description RetryWhenSubscriber(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<java.lang.Throwable> processor, org.reactivestreams.Subscription receiver)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onComplete()
void
onError(java.lang.Throwable t)
-
Methods inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableRepeatWhen.WhenSourceSubscriber
again, cancel, onNext, onSubscribe
-
Methods inherited from class io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter
isCancelled, isUnbounded, produced, request, setSubscription
-
Methods inherited from class java.util.concurrent.atomic.AtomicInteger
accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
RetryWhenSubscriber
RetryWhenSubscriber(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<java.lang.Throwable> processor, org.reactivestreams.Subscription receiver)
-
-