hu.akarnokd.reactive4java.util

Class Sink<T>

java.lang.Object

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

Type Parameters:

T - the element type

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

DefaultSink

public class Sink<T>
extends java.lang.Object
implements java.io.Closeable

Base class for implementing operators via lightweight sink that can be closed to prevent events to flow to the wrapped observer.

Since:

0.97

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicReference<java.io.Closeable>	cancel The reference to the cancel handler.
protected java.util.concurrent.atomic.AtomicReference<Observer<? super T>>	observer The reference to the observer.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	closeSilently() Convenience method to close this sink and suppress its exceptions.
Observer<T>	getForwarder()

Methods inherited from class java.lang.Object

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

Field Detail

observer

protected final java.util.concurrent.atomic.AtomicReference<Observer<? super T>> observer

The reference to the observer.

cancel

protected final java.util.concurrent.atomic.AtomicReference<java.io.Closeable> cancel

The reference to the cancel handler.

Constructor Detail

Sink

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

Constructor.

Parameters:

observer - the observer to wrap

cancel - the cancel handler to wrap

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

closeSilently

protected void closeSilently()

Convenience method to close this sink and suppress its exceptions.

getForwarder

public Observer<T> getForwarder()

Returns:

creates a new event forwarder for this sink.