net.fortytwo.flow

Class Tee<T>

java.lang.Object

net.fortytwo.flow.Tee<T>

Type Parameters:

T - the type of data being passed

All Implemented Interfaces:

Sink<T>

public class Tee<T>
extends Object
implements Sink<T>

A "tee" pipeline which passes data to both of two downstream sinks.

Constructor Summary

Constructors

Constructor and Description
Tee(Sink<T> left, Sink<T> right) Constructs a new tee using the given sinks

Method Summary

Methods

Modifier and Type	Method and Description
void	put(T t) Receives the next data item

Methods inherited from class java.lang.Object

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

Constructor Detail

Tee

public Tee(Sink<T> left,
   Sink<T> right)

Constructs a new tee using the given sinks

Parameters:

left - one of the two downstream sinks

right - the other of the two downstream sinks

Method Detail

put

public void put(T t)
         throws RippleException

Receives the next data item

Specified by:

put in interface Sink<T>

Parameters:

t - the data item being passed

Throws:

RippleException - if a data handling error occurs