Package rx.internal.operators

Class OperatorReplay.UnboundedReplayBuffer<T>

java.lang.Object

java.util.AbstractCollection<Object>

java.util.AbstractList<Object>

java.util.ArrayList<Object>

rx.internal.operators.OperatorReplay.UnboundedReplayBuffer<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

Serializable, Cloneable, Iterable<Object>, Collection<Object>, List<Object>, RandomAccess, SequencedCollection<Object>, OperatorReplay.ReplayBuffer<T>

Enclosing class:

OperatorReplay<T>

static final class OperatorReplay.UnboundedReplayBuffer<T>
extends ArrayList<Object>
implements OperatorReplay.ReplayBuffer<T>

Holds an unbounded list of events.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final NotificationLite<T>	nl
private static final long	serialVersionUID
(package private) int	size	The total number of events in the buffer.

Fields inherited from class java.util.AbstractList

modCount

Constructor Summary

Constructors

Constructor	Description
UnboundedReplayBuffer(int capacityHint)

Method Summary

Modifier and Type	Method	Description
void	complete()	Adds a completion event to the buffer
void	error(Throwable e)	Adds a terminal exception to the buffer
void	next(T value)	Adds a regular value to the buffer.
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.

Methods inherited from class java.util.ArrayList

add, add, addAll, addAll, addFirst, addLast, clear, clone, contains, ensureCapacity, equals, forEach, get, getFirst, getLast, hashCode, indexOf, isEmpty, iterator, lastIndexOf, listIterator, listIterator, remove, remove, removeAll, removeFirst, removeIf, removeLast, removeRange, replaceAll, retainAll, set, size, sort, spliterator, subList, toArray, toArray, trimToSize

Methods inherited from class java.util.AbstractCollection

containsAll, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Collection

parallelStream, stream, toArray

Methods inherited from interface java.util.List

containsAll, reversed

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

nl

final NotificationLite<T> nl

size

volatile int size

The total number of events in the buffer.

Constructor Details

UnboundedReplayBuffer

public UnboundedReplayBuffer(int capacityHint)

Method Details

next

public void next(T value)

Description copied from interface: OperatorReplay.ReplayBuffer

Adds a regular value to the buffer.

Specified by:

next in interface OperatorReplay.ReplayBuffer<T>

Parameters:

value -

error

public void error(Throwable e)

Description copied from interface: OperatorReplay.ReplayBuffer

Adds a terminal exception to the buffer

Specified by:

error in interface OperatorReplay.ReplayBuffer<T>

Parameters:

e -

complete

public void complete()

Description copied from interface: OperatorReplay.ReplayBuffer

Adds a completion event to the buffer

Specified by:

complete in interface OperatorReplay.ReplayBuffer<T>

replay

public 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 interface OperatorReplay.ReplayBuffer<T>

Parameters:

output -