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:
Serializable
- Enclosing class:
BufferUntilSubscriber<T>
The common state.
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final ConcurrentLinkedQueue
<Object> (package private) boolean
(package private) final Object
(package private) final NotificationLite
<T> private static final long
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(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 Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
guard
-
emitting
boolean emitting -
buffer
-
nl
-
-
Constructor Details
-
State
State()
-
-
Method Details
-
casObserverRef
-