Package rx.subjects

Class ReplaySubject.ReplayState<T>

Type Parameters:
T - the value type
All Implemented Interfaces:
Serializable, Action, Action1<Subscriber<? super T>>, Function, Observable.OnSubscribe<T>, Observer<T>
Enclosing class:
ReplaySubject<T>

static final class ReplaySubject.ReplayState<T> extends AtomicReference<ReplaySubject.ReplayProducer<T>[]> implements Observable.OnSubscribe<T>, Observer<T>
Holds onto the array of Subscriber-wrapping ReplayProducers and the buffer that holds values to be replayed; it manages subscription and signal dispatching.