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

Fields

Modifier and Type	Field	Description
(package private) final int	limit
private static final long	serialVersionUID

Fields inherited from class rx.internal.operators.OperatorReplay.BoundedReplayBuffer

index, nl, size, tail

Constructor Summary

Constructors

Constructor	Description
SizeBoundReplayBuffer(int limit)

Method Summary

Modifier and Type	Method	Description
(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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

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 class OperatorReplay.BoundedReplayBuffer<T>