Package io.reactivex.rxjava3.internal.operators.flowable

Class FlowablePublish.InnerSubscription<T>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicLong

io.reactivex.rxjava3.internal.operators.flowable.FlowablePublish.InnerSubscription<T>

All Implemented Interfaces:

Serializable, org.reactivestreams.Subscription

Enclosing class:

FlowablePublish<T>

static final class FlowablePublish.InnerSubscription<T>
extends AtomicLong
implements org.reactivestreams.Subscription

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final org.reactivestreams.Subscriber<? super T>	downstream
(package private) long	emitted
(package private) final FlowablePublish.PublishConnection<T>	parent
private static final long	serialVersionUID

Constructor Summary

Constructors

Constructor	Description
InnerSubscription(org.reactivestreams.Subscriber<? super T> downstream, FlowablePublish.PublishConnection<T> parent)

Method Summary

Modifier and Type	Method	Description
void	cancel()
boolean	isCancelled()
void	request(long n)

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

Methods inherited from class java.lang.Number

byteValue, shortValue

Methods inherited from class java.lang.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 T> downstream

parent

final FlowablePublish.PublishConnection<T> parent

emitted

long emitted

Constructor Details

InnerSubscription

InnerSubscription(org.reactivestreams.Subscriber<? super T> downstream,
 FlowablePublish.PublishConnection<T> parent)

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

isCancelled

public boolean isCancelled()