Package io.reactivex.rxjava3.subjects
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 -
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
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 Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
buffer
-
done
volatile boolean done -
size
volatile int size
-
-
Constructor Details
-
UnboundedReplayBuffer
UnboundedReplayBuffer(int capacityHint)
-
-
Method Details
-
add
- Specified by:
add
in interfaceReplaySubject.ReplayBuffer<T>
-
addFinal
- Specified by:
addFinal
in interfaceReplaySubject.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 interfaceReplaySubject.ReplayBuffer<T>
-
getValue
- Specified by:
getValue
in interfaceReplaySubject.ReplayBuffer<T>
-
getValues
- Specified by:
getValues
in interfaceReplaySubject.ReplayBuffer<T>
-
replay
- Specified by:
replay
in interfaceReplaySubject.ReplayBuffer<T>
-
size
public int size()- Specified by:
size
in interfaceReplaySubject.ReplayBuffer<T>
-