Class ObservableReplay.SizeBoundReplayBuffer<T>
java.lang.Object
java.util.concurrent.atomic.AtomicReference<ObservableReplay.Node>
io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.BoundedReplayBuffer<T>
io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.SizeBoundReplayBuffer<T>
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
ObservableReplay.ReplayBuffer<T>
,Serializable
- Enclosing class:
ObservableReplay<T>
static final class ObservableReplay.SizeBoundReplayBuffer<T>
extends ObservableReplay.BoundedReplayBuffer<T>
A bounded replay buffer implementation with size limit only.
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final int
private static final long
Fields inherited from class io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.BoundedReplayBuffer
eagerTruncate, size, tail
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) void
truncate()
Override this method to truncate a non-terminated buffer based on its current properties.Methods inherited from class io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.BoundedReplayBuffer
addLast, collect, complete, enterTransform, error, getHead, hasCompleted, hasError, leaveTransform, next, removeFirst, removeSome, replay, setFirst, trimHead, truncateFinal
Methods inherited from class java.util.concurrent.atomic.AtomicReference
accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
limit
final int limit
-
-
Constructor Details
-
SizeBoundReplayBuffer
SizeBoundReplayBuffer(int limit, boolean eagerTruncate)
-
-
Method Details
-
truncate
void truncate()Description copied from class:ObservableReplay.BoundedReplayBuffer
Override this method to truncate a non-terminated buffer based on its current properties.- Specified by:
truncate
in classObservableReplay.BoundedReplayBuffer<T>
-