Package io.reactivex.rxjava3.internal.operators.observable

Class ObservableReplay.UnboundedReplayBuffer<T>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractList<E>

java.util.ArrayList<java.lang.Object>

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

Type Parameters:

T - the value type

All Implemented Interfaces:

ObservableReplay.ReplayBuffer<T>, java.io.Serializable, java.lang.Cloneable, java.lang.Iterable<java.lang.Object>, java.util.Collection<java.lang.Object>, java.util.List<java.lang.Object>, java.util.RandomAccess

Enclosing class:

ObservableReplay<T>

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

Holds an unbounded list of events.

Field Summary

Fields

Modifier and Type	Field	Description
private static 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(java.lang.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 java.util.ArrayList

add, add, addAll, addAll, clear, clone, contains, ensureCapacity, equals, forEach, get, hashCode, indexOf, isEmpty, iterator, lastIndexOf, listIterator, listIterator, remove, remove, removeAll, removeIf, 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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

size

volatile int size

The total number of events in the buffer.

Constructor Detail

UnboundedReplayBuffer

UnboundedReplayBuffer(int capacityHint)

Method Detail

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(java.lang.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