Package rx.subjects
Class ReplaySubject.ReplayState<T>
- java.lang.Object
-
- java.util.concurrent.atomic.AtomicReference<ReplaySubject.ReplayProducer<T>[]>
-
- rx.subjects.ReplaySubject.ReplayState<T>
-
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
java.io.Serializable
,Action
,Action1<Subscriber<? super T>>
,Function
,Observable.OnSubscribe<T>
,Observer<T>
- Enclosing class:
- ReplaySubject<T>
static final class ReplaySubject.ReplayState<T> extends java.util.concurrent.atomic.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.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) ReplaySubject.ReplayBuffer<T>
buffer
(package private) static ReplaySubject.ReplayProducer[]
EMPTY
private static long
serialVersionUID
(package private) static ReplaySubject.ReplayProducer[]
TERMINATED
-
Constructor Summary
Constructors Constructor Description ReplayState(ReplaySubject.ReplayBuffer<T> buffer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) boolean
add(ReplaySubject.ReplayProducer<T> rp)
void
call(Subscriber<? super T> t)
(package private) boolean
isTerminated()
void
onCompleted()
Notifies the Observer that theObservable
has finished sending push-based notifications.void
onError(java.lang.Throwable e)
Notifies the Observer that theObservable
has experienced an error condition.void
onNext(T t)
Provides the Observer with a new item to observe.(package private) void
remove(ReplaySubject.ReplayProducer<T> rp)
-
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
-
buffer
final ReplaySubject.ReplayBuffer<T> buffer
-
EMPTY
static final ReplaySubject.ReplayProducer[] EMPTY
-
TERMINATED
static final ReplaySubject.ReplayProducer[] TERMINATED
-
-
Constructor Detail
-
ReplayState
public ReplayState(ReplaySubject.ReplayBuffer<T> buffer)
-
-
Method Detail
-
call
public void call(Subscriber<? super T> t)
-
add
boolean add(ReplaySubject.ReplayProducer<T> rp)
-
remove
void remove(ReplaySubject.ReplayProducer<T> rp)
-
onNext
public void onNext(T t)
Description copied from interface:Observer
Provides the Observer with a new item to observe.The
Observable
may call this method 0 or more times.The
Observable
will not call this method again after it calls eitherObserver.onCompleted()
orObserver.onError(java.lang.Throwable)
.
-
onError
public void onError(java.lang.Throwable e)
Description copied from interface:Observer
Notifies the Observer that theObservable
has experienced an error condition.If the
Observable
calls this method, it will not thereafter callObserver.onNext(T)
orObserver.onCompleted()
.
-
onCompleted
public void onCompleted()
Description copied from interface:Observer
Notifies the Observer that theObservable
has finished sending push-based notifications.The
Observable
will not call this method if it callsObserver.onError(java.lang.Throwable)
.- Specified by:
onCompleted
in interfaceObserver<T>
-
isTerminated
boolean isTerminated()
-
-