Package net.fortytwo.flow

Interface Summary

Mapping<D,R,C>	A data transformer which takes individual data items of one type (the "arguments"), maps them to zero or more items of a second type (the "solutions") and pushes the solutions into a downstream Sink
Sink<T>	The next step in a data pipeline.
Source<T>	A push-based data source which passes data to a downstream sink

Class Summary

Buffer<T>	A collection of data items which grows until "flushed" to a downstream sink.
Collector<T>	A data collector which stores data items in the order it receives them.
DistinctFilter<T>	A "filter" pipeline which allows each distinct data item to pass only once.
HistorySink<T>	A Sink which maintains a history of items received during any given interval between calls to its advance method.
NullSink<T>	A sink which simply throws away all data passed into it.
Switch<T>	A modal pipeline which passes data alternately to one of two downstream sinks
SynchronizedSink<T>	A pipeline which enforces one data item at a time, regardless of the number of threads writing into the sink.
Tee<T>	A "tee" pipeline which passes data to both of two downstream sinks.