Class FlowablePublishMulticast.MulticastSubscription<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicLong
io.reactivex.rxjava3.internal.operators.flowable.FlowablePublishMulticast.MulticastSubscription<T>
- All Implemented Interfaces:
Serializable
,org.reactivestreams.Subscription
- Enclosing class:
FlowablePublishMulticast<T,
R>
static final class FlowablePublishMulticast.MulticastSubscription<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 FlowablePublishMulticast.MulticastProcessor
<T> private static final long
-
Constructor Summary
ConstructorsConstructorDescriptionMulticastSubscription
(org.reactivestreams.Subscriber<? super T> actual, FlowablePublishMulticast.MulticastProcessor<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
-
MulticastSubscription
MulticastSubscription(org.reactivestreams.Subscriber<? super T> actual, FlowablePublishMulticast.MulticastProcessor<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()
-