hu.akarnokd.reactive4java.util

Class DefaultSink<T>

java.lang.Object

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

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

Type Parameters:

T - the element type

All Implemented Interfaces:

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

public class DefaultSink<T>
extends Sink<T>
implements Observer<T>

A default sink implementation which wraps an observer and closes a closeable on error or finish.

Since:

0.97

Field Summary

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

cancel, observer

Constructor Summary

Constructors

Constructor and Description
DefaultSink(Observer<? super T> observer, java.io.Closeable cancel) Constructor.

Method Summary

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.

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

close, closeSilently, getForwarder

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSink

public DefaultSink(Observer<? super T> observer,
                   java.io.Closeable cancel)

Constructor.

Parameters:

observer - the obserer to wrap

cancel - the cancellation callback

Method Detail

error

public void error(@Nonnull
                  java.lang.Throwable ex)

Description copied from interface: BaseObserver

An exception is received.

Specified by:

error in interface BaseObserver

Parameters:

ex - the exception

finish

public void finish()

Description copied from interface: BaseObserver

No more values to expect.

Specified by:

finish in interface BaseObserver

next

public void next(T value)

Description copied from interface: Observer

The next value is received.

Specified by:

next in interface Observer<T>

Parameters:

value - the next value