Package io.reactivex.rxjava3.processors
Interface ReplayProcessor.ReplayBuffer<T>
- Type Parameters:
T
- the value type
- All Known Implementing Classes:
ReplayProcessor.SizeAndTimeBoundReplayBuffer
,ReplayProcessor.SizeBoundReplayBuffer
,ReplayProcessor.UnboundedReplayBuffer
- Enclosing class:
ReplayProcessor<T>
static interface ReplayProcessor.ReplayBuffer<@NonNull T>
Abstraction over a buffer that receives events and replays them to
individual Subscribers.
-
Method Details
-
next
-
error
-
complete
void complete() -
replay
-
size
int size() -
getValue
-
getValues
-
isDone
boolean isDone() -
getError
Throwable getError() -
trimHead
void trimHead()Make sure an old inaccessible head value is released in a bounded buffer.
-