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:

Serializable, Runnable, org.reactivestreams.Subscription

Enclosing class:

FlowableInterval

static final class FlowableInterval.IntervalSubscriber
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 AtomicReference<Disposable>	resource
private static final long	serialVersionUID

Constructor Summary

Constructors

Constructor	Description
IntervalSubscriber(org.reactivestreams.Subscriber<? super Long> downstream)

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

count

long count

resource

final AtomicReference<Disposable> resource

Constructor Details

IntervalSubscriber

IntervalSubscriber(org.reactivestreams.Subscriber<? super Long> downstream)

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)