Interface ObservableReplay.ReplayBuffer<T>
- Type Parameters:
T
- the value type
- All Known Implementing Classes:
ObservableReplay.BoundedReplayBuffer
,ObservableReplay.SizeAndTimeBoundReplayBuffer
,ObservableReplay.SizeBoundReplayBuffer
,ObservableReplay.UnboundedReplayBuffer
- Enclosing class:
ObservableReplay<T>
static interface ObservableReplay.ReplayBuffer<T>
The interface for interacting with various buffering logic.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
complete()
Adds a completion event to the buffer.void
Adds a terminal exception to the buffer.void
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.
-
Method Details
-
next
Adds a regular value to the buffer.- Parameters:
value
- the value to be stored in the buffer
-
error
Adds a terminal exception to the buffer.- Parameters:
e
- the error to be stored in the buffer
-
complete
void complete()Adds a completion event to the buffer. -
replay
Tries to replay the buffered values to the subscriber inside the output if there is new value and requests available at the same time.- Parameters:
output
- the receiver of the buffered events
-