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,Throwable>
io.reactivex.rxjava3.internal.operators.flowable.FlowableRetryWhen.RetryWhenSubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,Serializable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
FlowableRetryWhen<T>
static final class FlowableRetryWhen.RetryWhenSubscriber<T>
extends FlowableRepeatWhen.WhenSourceSubscriber<T,Throwable>
-
Field Summary
FieldsFields 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
ConstructorsConstructorDescriptionRetryWhenSubscriber
(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<Throwable> processor, org.reactivestreams.Subscription receiver) -
Method Summary
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
Methods inherited from class java.lang.Number
byteValue, shortValue
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
-
Constructor Details
-
RetryWhenSubscriber
RetryWhenSubscriber(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<Throwable> processor, org.reactivestreams.Subscription receiver)
-
-
Method Details
-
onError
-
onComplete
public void onComplete()
-