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

Fields

Modifier and Type	Field	Description
private static final long	serialVersionUID

Fields inherited from class FlowableRepeatWhen.WhenSourceSubscriber

downstream, processor, receiver

Fields inherited from class SubscriptionArbiter

unbounded

Constructor Summary

Constructors

Constructor	Description
RetryWhenSubscriber(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<Throwable> processor, org.reactivestreams.Subscription receiver)

Method Summary

Modifier and Type	Method	Description
void	onComplete()
void	onError(Throwable t)

Methods inherited from class FlowableRepeatWhen.WhenSourceSubscriber

again, cancel, onNext, onSubscribe

Methods inherited from class SubscriptionArbiter

isCancelled, isUnbounded, produced, request, setSubscription

Methods inherited from class 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 Number

byteValue, shortValue

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

Constructor Details

RetryWhenSubscriber

RetryWhenSubscriber(org.reactivestreams.Subscriber<? super T> actual,
 FlowableProcessor<Throwable> processor,
 org.reactivestreams.Subscription receiver)

Method Details

onError

public void onError(Throwable t)

onComplete

public void onComplete()