Package rx.internal.operators
Class OperatorReplay.SizeBoundReplayBuffer<T>
java.lang.Object
java.util.concurrent.atomic.AtomicReference<OperatorReplay.Node>
rx.internal.operators.OperatorReplay.BoundedReplayBuffer<T>
rx.internal.operators.OperatorReplay.SizeBoundReplayBuffer<T>
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
Serializable
,OperatorReplay.ReplayBuffer<T>
- Enclosing class:
OperatorReplay<T>
static final class OperatorReplay.SizeBoundReplayBuffer<T>
extends OperatorReplay.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 rx.internal.operators.OperatorReplay.BoundedReplayBuffer
index, nl, 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 rx.internal.operators.OperatorReplay.BoundedReplayBuffer
addLast, collect, complete, enterTransform, error, getInitialHead, hasCompleted, hasError, leaveTransform, next, removeFirst, removeSome, replay, setFirst, 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
public SizeBoundReplayBuffer(int limit)
-
-
Method Details
-
truncate
void truncate()Description copied from class:OperatorReplay.BoundedReplayBuffer
Override this method to truncate a non-terminated buffer based on its current properties.- Overrides:
truncate
in classOperatorReplay.BoundedReplayBuffer<T>
-