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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidcomplete()Adds a completion event to the buffer.voiderror(java.lang.Throwable e)Adds a terminal exception to the buffer.voidnext(T value)Adds a regular value to the buffer.voidreplay(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 Detail
-
next
void next(T value)
Adds a regular value to the buffer.- Parameters:
value- the value to be stored in the buffer
-
error
void error(java.lang.Throwable e)
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
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.- Parameters:
output- the receiver of the buffered events
-
-