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:

Serializable, Runnable, org.reactivestreams.Subscription

Enclosing class:

FlowableIntervalRange

static final class FlowableIntervalRange.IntervalRangeSubscriber
extends AtomicLong
implements org.reactivestreams.Subscription, Runnable

Field Summary

Fields

Modifier and Type	Field	Description
(package private) long	count
(package private) final org.reactivestreams.Subscriber<? super Long>	downstream
(package private) final long	end
(package private) final AtomicReference<Disposable>	resource
private static final long	serialVersionUID

Constructor Summary

Constructors

Constructor	Description
IntervalRangeSubscriber(org.reactivestreams.Subscriber<? super Long> actual, long start, long end)

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	request(long n)
void	run()
void	setResource(Disposable d)

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

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

downstream

final org.reactivestreams.Subscriber<? super Long> downstream

end

final long end

count

long count

resource

final AtomicReference<Disposable> resource

Constructor Details

IntervalRangeSubscriber

IntervalRangeSubscriber(org.reactivestreams.Subscriber<? super Long> actual,
 long start,
 long end)

Method Details

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

run

public void run()

Specified by:

run in interface Runnable

setResource

public void setResource(Disposable d)