Class ObservableReplay.SizeAndTimeBoundReplayBuffer<T>

java.lang.Object

java.util.concurrent.atomic.AtomicReference<ObservableReplay.Node>

io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.BoundedReplayBuffer<T>

io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.SizeAndTimeBoundReplayBuffer<T>

Type Parameters:

T - the buffered value type

All Implemented Interfaces:

ObservableReplay.ReplayBuffer<T>, Serializable

Enclosing class:

ObservableReplay<T>

static final class ObservableReplay.SizeAndTimeBoundReplayBuffer<T>
extends ObservableReplay.BoundedReplayBuffer<T>

Size and time bound replay buffer.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final int	limit
(package private) final long	maxAge
(package private) final Scheduler	scheduler
private static final long	serialVersionUID
(package private) final TimeUnit	unit

Fields inherited from class ObservableReplay.BoundedReplayBuffer

eagerTruncate, size, tail

Constructor Summary

Constructors

Constructor	Description
SizeAndTimeBoundReplayBuffer(int limit, long maxAge, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)

Method Summary

Modifier and Type	Method	Description
(package private) Object	enterTransform(Object value)	Override this to wrap the NotificationLite object into a container to be used later by truncate.
(package private) ObservableReplay.Node	getHead()
(package private) Object	leaveTransform(Object value)	Override this to unwrap the transformed value into a NotificationLite object.
(package private) void	truncate()	Override this method to truncate a non-terminated buffer based on its current properties.
(package private) void	truncateFinal()	Override this method to truncate a terminated buffer based on its properties (i.e., truncate but the very last node).

Methods inherited from class ObservableReplay.BoundedReplayBuffer

addLast, collect, complete, error, hasCompleted, hasError, next, removeFirst, removeSome, replay, setFirst, trimHead

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

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

scheduler

final Scheduler scheduler

maxAge

final long maxAge

unit

final TimeUnit unit

limit

final int limit

Constructor Details

SizeAndTimeBoundReplayBuffer

SizeAndTimeBoundReplayBuffer(int limit,
 long maxAge,
 TimeUnit unit,
 Scheduler scheduler,
 boolean eagerTruncate)

Method Details

enterTransform

Object enterTransform(Object value)

Description copied from class: ObservableReplay.BoundedReplayBuffer

Override this to wrap the NotificationLite object into a container to be used later by truncate.

Overrides:

enterTransform in class ObservableReplay.BoundedReplayBuffer<T>

Parameters:

value - the value to transform into the internal representation

Returns:

the transformed value

leaveTransform

Object leaveTransform(Object value)

Description copied from class: ObservableReplay.BoundedReplayBuffer

Override this to unwrap the transformed value into a NotificationLite object.

Overrides:

leaveTransform in class ObservableReplay.BoundedReplayBuffer<T>

Parameters:

value - the value in the internal representation to transform

Returns:

the transformed value

truncate

void truncate()

Description copied from class: ObservableReplay.BoundedReplayBuffer

Override this method to truncate a non-terminated buffer based on its current properties.

Specified by:

truncate in class ObservableReplay.BoundedReplayBuffer<T>

truncateFinal

void truncateFinal()

Description copied from class: ObservableReplay.BoundedReplayBuffer

Override this method to truncate a terminated buffer based on its properties (i.e., truncate but the very last node).

Overrides:

truncateFinal in class ObservableReplay.BoundedReplayBuffer<T>

getHead

ObservableReplay.Node getHead()

Overrides:

getHead in class ObservableReplay.BoundedReplayBuffer<T>