DoStream streams data from the outlet to inlet.

FanOut creates a number of identical flows from the single outlet.

Flatten creates a Flow to flatten the stream of slices.

Merge merges multiple flows into a single flow.

NewFilter returns a new Filter instance.

NewFlatMap returns a new FlatMap instance.

NewMap returns a new Map instance.

NewPassThrough returns a new PassThrough instance.

RoundRobin creates a balanced number of flows from the single outlet.

Split splits the stream into two flows according to the given boolean predicate.

Filter filters incoming elements using a filter predicate.

FlatMap takes one element and produces zero, one, or more elements.

Map takes one element and produces one element.

PassThrough retransmits incoming elements as is.

FilterPredicate represents a filter predicate (boolean-valued function).

FlatMapFunction represents a FlatMap transformation function.

MapFunction represents a Map transformation function.