Class ObservableReplay.UnboundedReplayBuffer<T>

java.lang.Object

java.util.AbstractCollection<Object>

java.util.AbstractList<Object>

java.util.ArrayList<Object>

io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.UnboundedReplayBuffer<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

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

Enclosing class:

ObservableReplay<T>

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

Holds an unbounded list of events.

Field Summary

Fields

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

Fields inherited from class 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(ObservableReplay.InnerDisposable<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 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 AbstractCollection

containsAll, toString

Methods inherited from class Object

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

Methods inherited from interface Collection

parallelStream, stream, toArray

Methods inherited from interface List

containsAll, reversed

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

size

volatile int size

The total number of events in the buffer.

Constructor Details

UnboundedReplayBuffer

UnboundedReplayBuffer(int capacityHint)

Method Details

next

public void next(T value)

Description copied from interface: ObservableReplay.ReplayBuffer

Adds a regular value to the buffer.

Specified by:

next in interface ObservableReplay.ReplayBuffer<T>

Parameters:

value - the value to be stored in the buffer

error

public void error(Throwable e)

Description copied from interface: ObservableReplay.ReplayBuffer

Adds a terminal exception to the buffer.

Specified by:

error in interface ObservableReplay.ReplayBuffer<T>

Parameters:

e - the error to be stored in the buffer

complete

public void complete()

Description copied from interface: ObservableReplay.ReplayBuffer

Adds a completion event to the buffer.

Specified by:

complete in interface ObservableReplay.ReplayBuffer<T>

replay

public void replay(ObservableReplay.InnerDisposable<T> output)

Description copied from interface: ObservableReplay.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 ObservableReplay.ReplayBuffer<T>

Parameters:

output - the receiver of the buffered events