Package io.reactivex.rxjava3.subjects

Class ReplaySubject.SizeAndTimeBoundReplayBuffer<T>

java.lang.Object

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

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

All Implemented Interfaces:

ReplaySubject.ReplayBuffer<T>, java.io.Serializable

Enclosing class:

ReplaySubject<T>

static final class ReplaySubject.SizeAndTimeBoundReplayBuffer<T>
extends java.util.concurrent.atomic.AtomicReference<java.lang.Object>
implements ReplaySubject.ReplayBuffer<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	done
(package private) ReplaySubject.TimedNode<java.lang.Object>	head
(package private) long	maxAge
(package private) int	maxSize
(package private) Scheduler	scheduler
private static long	serialVersionUID
(package private) int	size
(package private) ReplaySubject.TimedNode<java.lang.Object>	tail
(package private) java.util.concurrent.TimeUnit	unit

Constructor Summary

Constructors

Constructor	Description
SizeAndTimeBoundReplayBuffer(int maxSize, long maxAge, java.util.concurrent.TimeUnit unit, Scheduler scheduler)

Method Summary

Modifier and Type	Method	Description
void	add(T value)
void	addFinal(java.lang.Object notificationLite)
(package private) ReplaySubject.TimedNode<java.lang.Object>	getHead()
T	getValue()
T[]	getValues(T[] array)
void	replay(ReplaySubject.ReplayDisposable<T> rs)
int	size()
(package private) int	size(ReplaySubject.TimedNode<java.lang.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 java.util.concurrent.atomic.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 java.lang.Object

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

Methods inherited from interface io.reactivex.rxjava3.subjects.ReplaySubject.ReplayBuffer

compareAndSet, get

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

maxSize

final int maxSize

maxAge

final long maxAge

unit

final java.util.concurrent.TimeUnit unit

scheduler

final Scheduler scheduler

size

int size

head

volatile ReplaySubject.TimedNode<java.lang.Object> head

tail

ReplaySubject.TimedNode<java.lang.Object> tail

done

volatile boolean done

Constructor Detail

SizeAndTimeBoundReplayBuffer

SizeAndTimeBoundReplayBuffer(int maxSize,
                             long maxAge,
                             java.util.concurrent.TimeUnit unit,
                             Scheduler scheduler)

Method Detail

trim

void trim()

trimFinal

void trimFinal()

add

public void add(T value)

Specified by:

add in interface ReplaySubject.ReplayBuffer<T>

addFinal

public void addFinal(java.lang.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<java.lang.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<java.lang.Object> h)