Class ReplayProcessor.SizeAndTimeBoundReplayBuffer<T>

java.lang.Object

io.reactivex.rxjava3.processors.ReplayProcessor.SizeAndTimeBoundReplayBuffer<T>

All Implemented Interfaces:

ReplayProcessor.ReplayBuffer<T>

Enclosing class:

ReplayProcessor<T>

static final class ReplayProcessor.SizeAndTimeBoundReplayBuffer<T>
extends Object
implements ReplayProcessor.ReplayBuffer<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	done
(package private) Throwable	error
(package private) ReplayProcessor.TimedNode<T>	head
(package private) final long	maxAge
(package private) final int	maxSize
(package private) final Scheduler	scheduler
(package private) int	size
(package private) ReplayProcessor.TimedNode<T>	tail
(package private) final TimeUnit	unit

Constructor Summary

Constructors

Constructor	Description
SizeAndTimeBoundReplayBuffer(int maxSize, long maxAge, TimeUnit unit, Scheduler scheduler)

Method Summary

Modifier and Type	Method	Description
void	complete()
void	error(Throwable ex)
Throwable	getError()
(package private) ReplayProcessor.TimedNode<T>	getHead()
T	getValue()
T[]	getValues(T[] array)
boolean	isDone()
void	next(T value)
void	replay(ReplayProcessor.ReplaySubscription<T> rs)
int	size()
(package private) int	size(ReplayProcessor.TimedNode<T> h)
(package private) void	trim()
(package private) void	trimFinal()
void	trimHead()	Make sure an old inaccessible head value is released in a bounded buffer.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

maxSize

final int maxSize

maxAge

final long maxAge

unit

final TimeUnit unit

scheduler

final Scheduler scheduler

size

int size

head

volatile ReplayProcessor.TimedNode<T> head

tail

ReplayProcessor.TimedNode<T> tail

error

Throwable error

done

volatile boolean done

Constructor Details

SizeAndTimeBoundReplayBuffer

SizeAndTimeBoundReplayBuffer(int maxSize,
 long maxAge,
 TimeUnit unit,
 Scheduler scheduler)

Method Details

trim

void trim()

trimFinal

void trimFinal()

trimHead

public void trimHead()

Description copied from interface: ReplayProcessor.ReplayBuffer

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

Specified by:

trimHead in interface ReplayProcessor.ReplayBuffer<T>

next

public void next(T value)

Specified by:

next in interface ReplayProcessor.ReplayBuffer<T>

error

public void error(Throwable ex)

Specified by:

error in interface ReplayProcessor.ReplayBuffer<T>

complete

public void complete()

Specified by:

complete in interface ReplayProcessor.ReplayBuffer<T>

getValue

@Nullable
public T getValue()

Specified by:

getValue in interface ReplayProcessor.ReplayBuffer<T>

getValues

public T[] getValues(T[] array)

Specified by:

getValues in interface ReplayProcessor.ReplayBuffer<T>

getHead

ReplayProcessor.TimedNode<T> getHead()

replay

public void replay(ReplayProcessor.ReplaySubscription<T> rs)

Specified by:

replay in interface ReplayProcessor.ReplayBuffer<T>

size

public int size()

Specified by:

size in interface ReplayProcessor.ReplayBuffer<T>

size

int size(ReplayProcessor.TimedNode<T> h)

getError

public Throwable getError()

Specified by:

getError in interface ReplayProcessor.ReplayBuffer<T>

isDone

public boolean isDone()

Specified by:

isDone in interface ReplayProcessor.ReplayBuffer<T>