Class ObservableCache.CacheDisposable<T>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.observable.ObservableCache.CacheDisposable<T>
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
Disposable
,Serializable
- Enclosing class:
ObservableCache<T>
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) boolean
(package private) long
(package private) ObservableCache.Node
<T> (package private) int
(package private) final ObservableCache
<T> private static final long
-
Constructor Summary
ConstructorsConstructorDescriptionCacheDisposable
(Observer<? super T> downstream, ObservableCache<T> parent) Constructs a new instance with the actual downstream consumer and the parent cache object. -
Method Summary
Modifier and TypeMethodDescriptionvoid
dispose()
Dispose the resource, the operation should be idempotent.boolean
Returns true if this resource has been disposed.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
-
node
ObservableCache.Node<T> node -
offset
int offset -
index
long index -
disposed
volatile boolean disposed
-
-
Constructor Details
-
CacheDisposable
CacheDisposable(Observer<? super T> downstream, ObservableCache<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
-
dispose
public void dispose()Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
-
isDisposed
public boolean isDisposed()Description copied from interface:Disposable
Returns true if this resource has been disposed.- Specified by:
isDisposed
in interfaceDisposable
- Returns:
- true if this resource has been disposed
-