Class FlowableIntervalRange.IntervalRangeSubscriber
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicLong
-
- io.reactivex.rxjava3.internal.operators.flowable.FlowableIntervalRange.IntervalRangeSubscriber
-
- All Implemented Interfaces:
java.io.Serializable
,java.lang.Runnable
,org.reactivestreams.Subscription
- Enclosing class:
- FlowableIntervalRange
static final class FlowableIntervalRange.IntervalRangeSubscriber 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) long
end
(package private) java.util.concurrent.atomic.AtomicReference<Disposable>
resource
private static long
serialVersionUID
-
Constructor Summary
Constructors Constructor Description IntervalRangeSubscriber(org.reactivestreams.Subscriber<? super java.lang.Long> actual, long start, long end)
-
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
-
end
final long end
-
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)
-
-