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 Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
complete()
void
error(java.lang.Throwable ex)
java.lang.Throwable
getError()
T
getValue()
T[]
getValues(@NonNull T[] array)
boolean
isDone()
void
next(@NonNull T value)
void
replay(ReplayProcessor.ReplaySubscription<@NonNull T> rs)
int
size()
void
trimHead()
Make sure an old inaccessible head value is released in a bounded buffer.
-
-
-
Method Detail
-
error
void error(java.lang.Throwable ex)
-
complete
void complete()
-
replay
void replay(ReplayProcessor.ReplaySubscription<@NonNull T> rs)
-
size
int size()
-
isDone
boolean isDone()
-
getError
java.lang.Throwable getError()
-
trimHead
void trimHead()
Make sure an old inaccessible head value is released in a bounded buffer.
-
-