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

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

next

void next(@NonNull T value)

error

void error(java.lang.Throwable ex)

complete

void complete()

replay

void replay(ReplayProcessor.ReplaySubscription<@NonNull T> rs)

size

int size()

getValue

@Nullable
T getValue()

getValues

T[] getValues(@NonNull T[] array)

isDone

boolean isDone()

getError

java.lang.Throwable getError()

trimHead

void trimHead()

Make sure an old inaccessible head value is released in a bounded buffer.