A B C D F G H I M N P S T W

A

advance() - Method in class net.fortytwo.flow.HistorySink

Advances to the next step in the history

apply(D, Sink<R>, C) - Method in interface net.fortytwo.flow.Mapping

Applies the mapping to a single argument, producing zero or more solutions and passing them into a downstream Sink

B

Buffer<T> - Class in net.fortytwo.flow

A collection of data items which grows until "flushed" to a downstream sink.

Buffer(Sink<T>) - Constructor for class net.fortytwo.flow.Buffer

Constructs a new buffer of the given type

C

clear() - Method in class net.fortytwo.flow.Collector

clear() - Method in class net.fortytwo.flow.diff.Diff

Collector<T> - Class in net.fortytwo.flow

A data collector which stores data items in the order it receives them.

Collector() - Constructor for class net.fortytwo.flow.Collector

Constructs a new collector

D

Diff<T> - Class in net.fortytwo.flow.diff

A two-channel data pipeline which distinguishes between data items "added" and "removed"

Diff() - Constructor for class net.fortytwo.flow.diff.Diff

DiffSink<T> - Interface in net.fortytwo.flow.diff

A pair of sinks, one for "added" data items and another for "removed" data items

DiffSource<T> - Interface in net.fortytwo.flow.diff

A source of two-channel "diff" data

DistinctFilter<T> - Class in net.fortytwo.flow

A "filter" pipeline which allows each distinct data item to pass only once.

DistinctFilter(Sink<T>) - Constructor for class net.fortytwo.flow.DistinctFilter

Constructs a new filter

F

flip() - Method in class net.fortytwo.flow.Switch

Toggles between the two downstream sinks.

flush() - Method in class net.fortytwo.flow.Buffer

Empties the buffer, pushing the collected data items in FIFO order to the downstream sink

G

get(int) - Method in class net.fortytwo.flow.HistorySink

Retrieves a data source for a given step in the history.

getMinus() - Method in class net.fortytwo.flow.diff.Diff

getMinus() - Method in interface net.fortytwo.flow.diff.DiffSink

getMinus() - Method in class net.fortytwo.flow.diff.NullDiffSink

getMutex() - Method in class net.fortytwo.flow.SynchronizedSink

getPlus() - Method in class net.fortytwo.flow.diff.Diff

getPlus() - Method in interface net.fortytwo.flow.diff.DiffSink

getPlus() - Method in class net.fortytwo.flow.diff.NullDiffSink

H

HistorySink<T> - Class in net.fortytwo.flow

A Sink which maintains a history of items received during any given interval between calls to its advance method.

HistorySink(int) - Constructor for class net.fortytwo.flow.HistorySink

Constructs a new history sink with a given capacity

I

isTransparent() - Method in interface net.fortytwo.flow.Mapping

iterator() - Method in class net.fortytwo.flow.Collector

M

Mapping<D,R,C> - Interface in net.fortytwo.flow

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

N

net.fortytwo.flow - package net.fortytwo.flow

net.fortytwo.flow.diff - package net.fortytwo.flow.diff

NullDiffSink<T> - Class in net.fortytwo.flow.diff

A trivial diff sink which simply throws away all of its input

NullDiffSink() - Constructor for class net.fortytwo.flow.diff.NullDiffSink

NullSink<T> - Class in net.fortytwo.flow

A sink which simply throws away all data passed into it.

NullSink() - Constructor for class net.fortytwo.flow.NullSink

P

put(T) - Method in class net.fortytwo.flow.Collector

Receives the next data item to be stored

put(T) - Method in class net.fortytwo.flow.DistinctFilter

Receives the next data item passed into this filter

put(T) - Method in class net.fortytwo.flow.HistorySink

Receives the next data item passed in.

put(T) - Method in class net.fortytwo.flow.NullSink

put(T) - Method in interface net.fortytwo.flow.Sink

Passes a data item into the Sink

put(T) - Method in class net.fortytwo.flow.Switch

Receives the next data item and passes it to the appropriate downstream sink.

put(T) - Method in class net.fortytwo.flow.SynchronizedSink

put(T) - Method in class net.fortytwo.flow.Tee

Receives the next data item

S

Sink<T> - Interface in net.fortytwo.flow

The next step in a data pipeline.

size() - Method in class net.fortytwo.flow.Collector

size() - Method in class net.fortytwo.flow.diff.Diff

Source<T> - Interface in net.fortytwo.flow

A push-based data source which passes data to a downstream sink

Switch<T> - Class in net.fortytwo.flow

A modal pipeline which passes data alternately to one of two downstream sinks

Switch(Sink<T>, Sink<T>) - Constructor for class net.fortytwo.flow.Switch

Constructs a new switch over the given sinks

SynchronizedSink<T> - Class in net.fortytwo.flow

A pipeline which enforces one data item at a time, regardless of the number of threads writing into the sink.

SynchronizedSink(Sink<T>, Object) - Constructor for class net.fortytwo.flow.SynchronizedSink

Constructs a new synchronized sink using a specified mutex

SynchronizedSink(Sink<T>) - Constructor for class net.fortytwo.flow.SynchronizedSink

Constructs a new synchronized sink using an internal mutex

T

Tee<T> - Class in net.fortytwo.flow

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

Tee(Sink<T>, Sink<T>) - Constructor for class net.fortytwo.flow.Tee

Constructs a new tee using the given sinks

W

writeTo(Sink<T>) - Method in class net.fortytwo.flow.Collector

Pushes the collected items to the specified sink.

writeTo(DiffSink<T>) - Method in class net.fortytwo.flow.diff.Diff

writeTo(DiffSink<T>) - Method in interface net.fortytwo.flow.diff.DiffSource

Writes all of the data in this source to the specified diff sink

writeTo(Sink<T>) - Method in interface net.fortytwo.flow.Source

Pushes this source's data into a given sink

A B C D F G H I M N P S T W