Class FlowableInterval.IntervalSubscriber
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicLong
-
- io.reactivex.rxjava3.internal.operators.flowable.FlowableInterval.IntervalSubscriber
-
- All Implemented Interfaces:
java.io.Serializable
,java.lang.Runnable
,org.reactivestreams.Subscription
- Enclosing class:
- FlowableInterval
static final class FlowableInterval.IntervalSubscriber extends java.util.concurrent.atomic.AtomicLong implements org.reactivestreams.Subscription, java.lang.Runnable
-
-
Field Summary
Fields Modifier and Type Field Description (package private) long
count
(package private) org.reactivestreams.Subscriber<? super java.lang.Long>
downstream
(package private) java.util.concurrent.atomic.AtomicReference<Disposable>
resource
private static long
serialVersionUID
-
Constructor Summary
Constructors Constructor Description IntervalSubscriber(org.reactivestreams.Subscriber<? super java.lang.Long> downstream)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
void
request(long n)
void
run()
void
setResource(Disposable d)
-
Methods inherited from class java.util.concurrent.atomic.AtomicLong
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
-
downstream
final org.reactivestreams.Subscriber<? super java.lang.Long> downstream
-
count
long count
-
resource
final java.util.concurrent.atomic.AtomicReference<Disposable> resource
-
-
Method Detail
-
request
public void request(long n)
- Specified by:
request
in interfaceorg.reactivestreams.Subscription
-
cancel
public void cancel()
- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
setResource
public void setResource(Disposable d)
-
-