Class FlowableCache.CacheSubscription<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.flowable.FlowableCache.CacheSubscription<T>
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
Serializable
,org.reactivestreams.Subscription
- Enclosing class:
FlowableCache<T>
static final class FlowableCache.CacheSubscription<T>
extends AtomicInteger
implements org.reactivestreams.Subscription
Hosts the downstream consumer and its current requested and replay states.
this
holds the work-in-progress counter for the serialized replay.-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final org.reactivestreams.Subscriber
<? super T> (package private) long
(package private) FlowableCache.Node
<T> (package private) int
(package private) final FlowableCache
<T> (package private) final AtomicLong
private static final long
-
Constructor Summary
ConstructorsConstructorDescriptionCacheSubscription
(org.reactivestreams.Subscriber<? super T> downstream, FlowableCache<T> parent) Constructs a new instance with the actual downstream consumer and the parent cache object. -
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
-
parent
-
requested
-
node
FlowableCache.Node<T> node -
offset
int offset -
index
long index
-
-
Constructor Details
-
CacheSubscription
CacheSubscription(org.reactivestreams.Subscriber<? super T> downstream, FlowableCache<T> parent) Constructs a new instance with the actual downstream consumer and the parent cache object.- Parameters:
downstream
- the actual consumerparent
- the parent that holds onto the cached items
-
-
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
-