Package rx.internal.operators
Class CachedObservable.CachedSubscribe<T>
java.lang.Object
java.util.concurrent.atomic.AtomicBoolean
rx.internal.operators.CachedObservable.CachedSubscribe<T>
- Type Parameters:
T
- the value type emitted
- All Implemented Interfaces:
Serializable
,Action
,Action1<Subscriber<? super T>>
,Function
,Observable.OnSubscribe<T>
- Enclosing class:
CachedObservable<T>
static final class CachedObservable.CachedSubscribe<T>
extends AtomicBoolean
implements Observable.OnSubscribe<T>
Manages the subscription of child subscribers by setting up a replay producer and
performs auto-connection of the very first subscription.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final long
(package private) final CachedObservable.CacheState
<T> -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class java.util.concurrent.atomic.AtomicBoolean
compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndSet, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile