Package io.reactivex.rxjava3.processors
Class ReplayProcessor.TimedNode<T>
java.lang.Object
java.util.concurrent.atomic.AtomicReference<ReplayProcessor.TimedNode<T>>
io.reactivex.rxjava3.processors.ReplayProcessor.TimedNode<T>
- All Implemented Interfaces:
Serializable
- Enclosing class:
ReplayProcessor<T>
static final class ReplayProcessor.TimedNode<T>
extends AtomicReference<ReplayProcessor.TimedNode<T>>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final long
(package private) final long
(package private) final T
-
Constructor Summary
Constructors -
Method Summary
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
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
value
-
time
final long time
-
-
Constructor Details
-
TimedNode
TimedNode(T value, long time)
-