Package io.reactivex.rxjava3.processors
Class ReplayProcessor.ReplaySubscription<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.processors.ReplayProcessor.ReplaySubscription<T>
- All Implemented Interfaces:
Serializable
,org.reactivestreams.Subscription
- Enclosing class:
ReplayProcessor<T>
static final class ReplayProcessor.ReplaySubscription<@NonNull T>
extends AtomicInteger
implements org.reactivestreams.Subscription
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) final org.reactivestreams.Subscriber
<? super T> (package private) long
(package private) Object
(package private) final AtomicLong
private static final long
(package private) final ReplayProcessor
<T> -
Constructor Summary
ConstructorsConstructorDescriptionReplaySubscription
(org.reactivestreams.Subscriber<? super @NonNull T> actual, ReplayProcessor<@NonNull T> state) -
Method Summary
Methods inherited from class java.util.concurrent.atomic.AtomicInteger
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
-
state
-
index
Object index -
requested
-
cancelled
volatile boolean cancelled -
emitted
long emitted
-
-
Constructor Details
-
ReplaySubscription
ReplaySubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, ReplayProcessor<@NonNull T> state)
-
-
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
-