Class ReplaySubject.UnboundedReplayBuffer<T>

java.lang.Object

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

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

All Implemented Interfaces:

ReplaySubject.ReplayBuffer<T>, Serializable

Enclosing class:

ReplaySubject<T>

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

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final List<Object>	buffer
(package private) boolean	done
private static final long	serialVersionUID
(package private) int	size

Constructor Summary

Constructors

Constructor	Description
UnboundedReplayBuffer(int capacityHint)

Method Summary

Modifier and Type	Method	Description
void	add(T value)
void	addFinal(Object notificationLite)
T	getValue()
T[]	getValues(T[] array)
void	replay(ReplaySubject.ReplayDisposable<T> rs)
int	size()
void	trimHead()	Make sure an old inaccessible head value is released in a bounded buffer.

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

buffer

final List<Object> buffer

done

volatile boolean done

size

volatile int size

Constructor Details

UnboundedReplayBuffer

UnboundedReplayBuffer(int capacityHint)

Method Details

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()

Description copied from interface: ReplaySubject.ReplayBuffer

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

Specified by:

trimHead in interface ReplaySubject.ReplayBuffer<T>

getValue

@Nullable
public T getValue()

Specified by:

getValue in interface ReplaySubject.ReplayBuffer<T>

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>