T - the element typepublic class DefaultSink<T> extends Sink<T> implements Observer<T>
| Constructor and Description |
|---|
DefaultSink(Observer<? super T> observer,
java.io.Closeable cancel)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
error(java.lang.Throwable ex)
An exception is received.
|
void |
finish()
No more values to expect.
|
void |
next(T value)
The next value is received.
|
close, closeSilently, getForwarderpublic void error(@Nonnull
java.lang.Throwable ex)
BaseObservererror in interface BaseObserverex - the exceptionpublic void finish()
BaseObserverfinish in interface BaseObserver