Class ReplaySubject.SizeAndTimeBoundReplayBuffer<T>

java.lang.Object

java.util.concurrent.atomic.AtomicReference<Object>

io.reactivex.rxjava3.subjects.ReplaySubject.SizeAndTimeBoundReplayBuffer<T>

All Implemented Interfaces:

ReplaySubject.ReplayBuffer<T>, Serializable

Enclosing class:

ReplaySubject<T>

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

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	done
(package private) ReplaySubject.TimedNode<Object>	head
(package private) final long	maxAge
(package private) final int	maxSize
(package private) final Scheduler	scheduler
private static final long	serialVersionUID
(package private) int	size
(package private) ReplaySubject.TimedNode<Object>	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	add(T value)
void	addFinal(Object notificationLite)
(package private) ReplaySubject.TimedNode<Object>	getHead()
T	getValue()
T[]	getValues(T[] array)
void	replay(ReplaySubject.ReplayDisposable<T> rs)
int	size()
(package private) int	size(ReplaySubject.TimedNode<Object> h)
(package private) void	trim()
(package private) void	trimFinal()
void	trimHead()	Replace a non-empty head node with an empty one to allow the GC of the inaccessible old value.

Methods inherited from class AtomicReference

accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile

Methods inherited from class Object

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

Methods inherited from interface ReplaySubject.ReplayBuffer

compareAndSet, get

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

maxSize

final int maxSize

maxAge

final long maxAge

unit

final TimeUnit unit

scheduler

final Scheduler scheduler

size

int size

head

volatile ReplaySubject.TimedNode<Object> head

tail

ReplaySubject.TimedNode<Object> tail

done

volatile boolean done

Constructor Details

SizeAndTimeBoundReplayBuffer

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

Method Details

trim

void trim()

trimFinal

void trimFinal()

add

public void add(T value)

Specified by:

add in interface ReplaySubject.ReplayBuffer<T>

addFinal

public void addFinal(Object notificationLite)

Specified by:

addFinal in interface ReplaySubject.ReplayBuffer<T>

trimHead

public void trimHead()

Replace a non-empty head node with an empty one to allow the GC of the inaccessible old value.

Specified by:

trimHead in interface ReplaySubject.ReplayBuffer<T>

getValue

@Nullable
public T getValue()

Specified by:

getValue in interface ReplaySubject.ReplayBuffer<T>

getHead

ReplaySubject.TimedNode<Object> getHead()

getValues

public T[] getValues(T[] array)

Specified by:

getValues in interface ReplaySubject.ReplayBuffer<T>

replay

public void replay(ReplaySubject.ReplayDisposable<T> rs)

Specified by:

replay in interface ReplaySubject.ReplayBuffer<T>

size

public int size()

Specified by:

size in interface ReplaySubject.ReplayBuffer<T>

size

int size(ReplaySubject.TimedNode<Object> h)