Uses of Interface
net.fortytwo.flow.Sink

Packages that use Sink

net.fortytwo.flow
net.fortytwo.flow.diff

Uses of Sink in net.fortytwo.flow

Classes in net.fortytwo.flow that implement Sink

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

Methods in net.fortytwo.flow with parameters of type Sink

void	Mapping.apply(D arg, Sink<R> solutions, C context) Applies the mapping to a single argument, producing zero or more solutions and passing them into a downstream Sink
void	Source.writeTo(Sink<T> sink) Pushes this source's data into a given sink
void	Collector.writeTo(Sink<T> sink) Pushes the collected items to the specified sink.

Constructors in net.fortytwo.flow with parameters of type Sink

Buffer(Sink<T> sink)
Constructs a new buffer of the given type

DistinctFilter(Sink<T> sink)
Constructs a new filter

Switch(Sink<T> left, Sink<T> right)
Constructs a new switch over the given sinks

Switch(Sink<T> left, Sink<T> right)
Constructs a new switch over the given sinks

SynchronizedSink(Sink<T> other)
Constructs a new synchronized sink using an internal mutex

SynchronizedSink(Sink<T> other, Object mutex)
Constructs a new synchronized sink using a specified mutex

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

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

Uses of Sink in net.fortytwo.flow.diff

Methods in net.fortytwo.flow.diff that return Sink

Sink<T>	NullDiffSink.getMinus()
Sink<T>	DiffSink.getMinus()
Sink<T>	Diff.getMinus()
Sink<T>	NullDiffSink.getPlus()
Sink<T>	DiffSink.getPlus()
Sink<T>	Diff.getPlus()