Package rx.internal.operators
Class OperatorReplay.BoundedReplayBuffer<T>
- java.lang.Object
-
- java.util.concurrent.atomic.AtomicReference<OperatorReplay.Node>
-
- rx.internal.operators.OperatorReplay.BoundedReplayBuffer<T>
-
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
java.io.Serializable
,OperatorReplay.ReplayBuffer<T>
- Direct Known Subclasses:
OperatorReplay.SizeAndTimeBoundReplayBuffer
,OperatorReplay.SizeBoundReplayBuffer
- Enclosing class:
- OperatorReplay<T>
static class OperatorReplay.BoundedReplayBuffer<T> extends java.util.concurrent.atomic.AtomicReference<OperatorReplay.Node> implements OperatorReplay.ReplayBuffer<T>
Base class for bounded buffering with options to specify an enter and leave transforms and custom truncation behavior.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) long
index
The total number of received values so far.(package private) NotificationLite<T>
nl
private static long
serialVersionUID
(package private) int
size
(package private) OperatorReplay.Node
tail
-
Constructor Summary
Constructors Constructor Description BoundedReplayBuffer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
addLast(OperatorReplay.Node n)
Add a new node to the linked list.(package private) void
collect(java.util.Collection<? super T> output)
void
complete()
Adds a completion event to the buffer(package private) java.lang.Object
enterTransform(java.lang.Object value)
Override this to wrap the NotificationLite object into a container to be used later by truncate.void
error(java.lang.Throwable e)
Adds a terminal exception to the buffer(package private) OperatorReplay.Node
getInitialHead()
Returns the current head for initializing the replay location for a new subscriber.(package private) boolean
hasCompleted()
(package private) boolean
hasError()
(package private) java.lang.Object
leaveTransform(java.lang.Object value)
Override this to unwrap the transformed value into a NotificationLite object.void
next(T value)
Adds a regular value to the buffer.(package private) void
removeFirst()
Remove the first node from the linked list.(package private) void
removeSome(int n)
void
replay(OperatorReplay.InnerProducer<T> output)
Tries to replay the buffered values to the subscriber inside the output if there is new value and requests available at the same time.(package private) void
setFirst(OperatorReplay.Node n)
Arranges the given node is the new head from now on.(package private) void
truncate()
Override this method to truncate a non-terminated buffer based on its current properties.(package private) void
truncateFinal()
Override this method to truncate a terminated buffer based on its properties (i.e., truncate but the very last node).-
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 Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
nl
final NotificationLite<T> nl
-
tail
OperatorReplay.Node tail
-
size
int size
-
index
long index
The total number of received values so far.
-
-
Method Detail
-
addLast
final void addLast(OperatorReplay.Node n)
Add a new node to the linked list.- Parameters:
n
-
-
removeFirst
final void removeFirst()
Remove the first node from the linked list.
-
removeSome
final void removeSome(int n)
-
setFirst
final void setFirst(OperatorReplay.Node n)
Arranges the given node is the new head from now on.- Parameters:
n
-
-
getInitialHead
OperatorReplay.Node getInitialHead()
Returns the current head for initializing the replay location for a new subscriber. Override it to consider linked but outdated elements.- Returns:
- the current head
-
next
public final void next(T value)
Description copied from interface:OperatorReplay.ReplayBuffer
Adds a regular value to the buffer.- Specified by:
next
in interfaceOperatorReplay.ReplayBuffer<T>
-
error
public final void error(java.lang.Throwable e)
Description copied from interface:OperatorReplay.ReplayBuffer
Adds a terminal exception to the buffer- Specified by:
error
in interfaceOperatorReplay.ReplayBuffer<T>
-
complete
public final void complete()
Description copied from interface:OperatorReplay.ReplayBuffer
Adds a completion event to the buffer- Specified by:
complete
in interfaceOperatorReplay.ReplayBuffer<T>
-
replay
public final void replay(OperatorReplay.InnerProducer<T> output)
Description copied from interface:OperatorReplay.ReplayBuffer
Tries to replay the buffered values to the subscriber inside the output if there is new value and requests available at the same time.- Specified by:
replay
in interfaceOperatorReplay.ReplayBuffer<T>
-
enterTransform
java.lang.Object enterTransform(java.lang.Object value)
Override this to wrap the NotificationLite object into a container to be used later by truncate.- Parameters:
value
-- Returns:
-
leaveTransform
java.lang.Object leaveTransform(java.lang.Object value)
Override this to unwrap the transformed value into a NotificationLite object.- Parameters:
value
-- Returns:
-
truncate
void truncate()
Override this method to truncate a non-terminated buffer based on its current properties.
-
truncateFinal
void truncateFinal()
Override this method to truncate a terminated buffer based on its properties (i.e., truncate but the very last node).
-
collect
final void collect(java.util.Collection<? super T> output)
-
hasError
boolean hasError()
-
hasCompleted
boolean hasCompleted()
-
-