Class FlowableRepeatWhen.RepeatWhenSubscriber<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,Object>
io.reactivex.rxjava3.internal.operators.flowable.FlowableRepeatWhen.RepeatWhenSubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,Serializable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
FlowableRepeatWhen<T>
static final class FlowableRepeatWhen.RepeatWhenSubscriber<T>
extends FlowableRepeatWhen.WhenSourceSubscriber<T,Object>
-
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
ConstructorsConstructorDescriptionRepeatWhenSubscriber
(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<Object> 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
-
RepeatWhenSubscriber
RepeatWhenSubscriber(org.reactivestreams.Subscriber<? super T> actual, FlowableProcessor<Object> processor, org.reactivestreams.Subscription receiver)
-
-
Method Details
-
onError
-
onComplete
public void onComplete()
-