Package rx.internal.operators
Class BufferUntilSubscriber.State<T>
- java.lang.Object
-
- java.util.concurrent.atomic.AtomicReference<Observer<? super T>>
-
- rx.internal.operators.BufferUntilSubscriber.State<T>
-
- All Implemented Interfaces:
java.io.Serializable
- Enclosing class:
- BufferUntilSubscriber<T>
static final class BufferUntilSubscriber.State<T> extends java.util.concurrent.atomic.AtomicReference<Observer<? super T>>
The common state.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) java.util.concurrent.ConcurrentLinkedQueue<java.lang.Object>
buffer
(package private) boolean
emitting
(package private) java.lang.Object
guard
(package private) NotificationLite<T>
nl
private static long
serialVersionUID
-
Constructor Summary
Constructors Constructor Description State()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) boolean
casObserverRef(Observer<? super T> expected, Observer<? super T> next)
-
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 Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
guard
final java.lang.Object guard
-
emitting
boolean emitting
-
buffer
final java.util.concurrent.ConcurrentLinkedQueue<java.lang.Object> buffer
-
nl
final NotificationLite<T> nl
-
-