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:
java.io.Serializable
,org.reactivestreams.Subscription
- Enclosing class:
- ReplayProcessor<T>
static final class ReplayProcessor.ReplaySubscription<@NonNull T> extends java.util.concurrent.atomic.AtomicInteger implements org.reactivestreams.Subscription
-
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
cancelled
(package private) org.reactivestreams.Subscriber<? super T>
downstream
(package private) long
emitted
(package private) java.lang.Object
index
(package private) java.util.concurrent.atomic.AtomicLong
requested
private static long
serialVersionUID
(package private) ReplayProcessor<T>
state
-
Constructor Summary
Constructors Constructor Description ReplaySubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, ReplayProcessor<@NonNull T> state)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
void
request(long n)
-
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
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
downstream
final org.reactivestreams.Subscriber<? super T> downstream
-
state
final ReplayProcessor<T> state
-
index
java.lang.Object index
-
requested
final java.util.concurrent.atomic.AtomicLong requested
-
cancelled
volatile boolean cancelled
-
emitted
long emitted
-
-
Constructor Detail
-
ReplaySubscription
ReplaySubscription(org.reactivestreams.Subscriber<? super @NonNull T> actual, ReplayProcessor<@NonNull T> state)
-
-