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.
-
Constructor Summary
Constructors Constructor Description UnboundedReplayBuffer(int capacityHint)
-
Method Summary
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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.
-
-
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 interfaceObservableReplay.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 interfaceObservableReplay.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 interfaceObservableReplay.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 interfaceObservableReplay.ReplayBuffer<T>
- Parameters:
output
- the receiver of the buffered events
-
-