hu.akarnokd.reactive4java.reactive

Class Zip.ManyObservables.ItemObserver<T>

java.lang.Object

hu.akarnokd.reactive4java.util.DefaultObserver<T>

hu.akarnokd.reactive4java.util.DefaultObserverEx<T>

hu.akarnokd.reactive4java.reactive.Zip.ManyObservables.ItemObserver<T>

Type Parameters:

T - the element type

All Implemented Interfaces:

BaseObserver, Observer<T>, java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

Zip.ManyObservables<T,U>

public static class Zip.ManyObservables.ItemObserver<T>
extends DefaultObserverEx<T>

The individual line's observer.

Field Summary

Fields

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.

Fields inherited from class hu.akarnokd.reactive4java.util.DefaultObserverEx

subObservers

Fields inherited from class hu.akarnokd.reactive4java.util.DefaultObserver

closeOnTermination, completed, lock

Constructor Summary

Constructors

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.

Method Summary

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.

Methods inherited from class hu.akarnokd.reactive4java.util.DefaultObserverEx

add, init, onClose, onRegister, registerWith, remove, wrap

Methods inherited from class hu.akarnokd.reactive4java.util.DefaultObserver

close, error, finish, getLock, isCompleted, next

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

rwLock

protected final java.util.concurrent.locks.ReadWriteLock rwLock

Reader-writer lock.

queue

public final java.util.Queue<java.lang.Object> queue

The queue.

done

public boolean done

Indicate completion of this stream.

all

public final java.util.List<Zip.ManyObservables.ItemObserver<T>> all

The list of the other observers.

NULL_SENTINEL

protected static final java.lang.Object NULL_SENTINEL

The null sentinel value.

cancel

protected final java.io.Closeable cancel

The global cancel.

source

protected final Observable<? extends T> source

The source.

observer

protected final Observer<? super java.util.List<T>> observer

The observer.

Constructor Detail

ItemObserver

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)

Constructor.

Parameters:

rwLock - the reader-writer lock to use

all - all observers

source - the source sequence

observer - the output observer

cancel - the cancellation handler

Method Detail

onNext

protected void onNext(T value)

Description copied from class: DefaultObserver

The alternative next() method, which is called by the original next() method under lock.

Specified by:

onNext in class DefaultObserver<T>

Parameters:

value - the value

onError

protected void onError(java.lang.Throwable ex)

Description copied from class: DefaultObserver

The alternative error() method, which is called by the original error() method.

Specified by:

onError in class DefaultObserver<T>

Parameters:

ex - the exception

onFinish

protected void onFinish()

Description copied from class: DefaultObserver

The alternative finish() method, which is called by the original finish() method.

Specified by:

onFinish in class DefaultObserver<T>

connect

public void connect()

Connect to the source.