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
FieldsModifier and TypeFieldDescription(package private) final org.reactivestreams.Subscriber
<? super T> (package private) long
(package private) final FlowablePublish.PublishConnection
<T> private static final long
-
Constructor Summary
ConstructorsConstructorDescriptionInnerSubscription
(org.reactivestreams.Subscriber<? super T> downstream, FlowablePublish.PublishConnection<T> parent) -
Method Summary
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
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
downstream
-
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 interfaceorg.reactivestreams.Subscription
-
cancel
public void cancel()- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-
isCancelled
public boolean isCancelled()
-