T - the element typepublic class SynchronizedObserver<T> extends java.lang.Object implements Observer<T>, java.io.Closeable
| Modifier and Type | Field and Description |
|---|---|
protected java.lang.Object |
gate
The lock object.
|
protected Observer<T> |
observer
The wrapped observer.
|
| Constructor and Description |
|---|
SynchronizedObserver(Observer<T> o)
Constructor, sets the wrapped observer and uses an internal object as gate.
|
SynchronizedObserver(Observer<T> o,
java.lang.Object gate)
Constructor, sets the wrapped observer and uses the provided lock.
|
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
error(java.lang.Throwable ex)
An exception is received.
|
void |
finish()
No more values to expect.
|
java.lang.Object |
getGate() |
void |
next(T value)
The next value is received.
|
public SynchronizedObserver(@Nonnull
Observer<T> o)
o - the observerpublic java.lang.Object getGate()
public void close()
throws java.io.IOException
close in interface java.io.Closeableclose in interface java.lang.AutoCloseablejava.io.IOExceptionpublic void next(T value)
Observerpublic void error(@Nonnull
java.lang.Throwable ex)
BaseObservererror in interface BaseObserverex - the exceptionpublic void finish()
BaseObserverfinish in interface BaseObserver