T - the element typepublic static class Zip.ManyObservables.ItemObserver<T> extends DefaultObserverEx<T>
| Modifier and Type | Field and Description |
|---|---|
java.util.List<Zip.ManyObservables.ItemObserver<T>> |
all
The list of the other observers.
|
protected java.io.Closeable |
cancel
The global cancel.
|
boolean |
done
Indicate completion of this stream.
|
protected static java.lang.Object |
NULL_SENTINEL
The null sentinel value.
|
protected Observer<? super java.util.List<T>> |
observer
The observer.
|
java.util.Queue<java.lang.Object> |
queue
The queue.
|
protected java.util.concurrent.locks.ReadWriteLock |
rwLock
Reader-writer lock.
|
protected Observable<? extends T> |
source
The source.
|
subObserverscloseOnTermination, completed, lock| Constructor and Description |
|---|
ItemObserver(java.util.concurrent.locks.ReadWriteLock rwLock,
java.util.List<Zip.ManyObservables.ItemObserver<T>> all,
Observable<? extends T> source,
Observer<? super java.util.List<T>> observer,
java.io.Closeable cancel)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
connect()
Connect to the source.
|
protected void |
onError(java.lang.Throwable ex)
The alternative error() method, which is called by the original error() method.
|
protected void |
onFinish()
The alternative finish() method, which is called by the original finish() method.
|
protected void |
onNext(T value)
The alternative next() method, which is called by the original next() method
under lock.
|
add, init, onClose, onRegister, registerWith, remove, wrapclose, error, finish, getLock, isCompleted, nextprotected final java.util.concurrent.locks.ReadWriteLock rwLock
public final java.util.Queue<java.lang.Object> queue
public boolean done
public final java.util.List<Zip.ManyObservables.ItemObserver<T>> all
protected static final java.lang.Object NULL_SENTINEL
protected final java.io.Closeable cancel
protected final Observable<? extends T> source
public ItemObserver(java.util.concurrent.locks.ReadWriteLock rwLock,
java.util.List<Zip.ManyObservables.ItemObserver<T>> all,
Observable<? extends T> source,
Observer<? super java.util.List<T>> observer,
java.io.Closeable cancel)
rwLock - the reader-writer lock to useall - all observerssource - the source sequenceobserver - the output observercancel - the cancellation handlerprotected void onNext(T value)
DefaultObserveronNext in class DefaultObserver<T>value - the valueprotected void onError(java.lang.Throwable ex)
DefaultObserveronError in class DefaultObserver<T>ex - the exceptionprotected void onFinish()
DefaultObserveronFinish in class DefaultObserver<T>public void connect()