DoStream streams data from the outlet to inlet.

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

Merge merges multiple flows into a single flow.

NewFilter returns a new Filter instance.

NewFlatMap returns a new FlatMap instance.

NewItem returns a new Item.

NewMap returns a new Map instance.

NewPassThrough returns a new PassThrough instance.

NewSlidingWindow returns a new processing time based SlidingWindow.

NewSlidingWindowWithTSExtractor returns a new event time based SlidingWindow.

NewThrottler returns a new Throttler instance.

NewTumblingWindow returns a new TumblingWindow instance.

Split splits the stream into two flows according to some criterion.

Backpressure on overflow mode.

Discard elements on overflow mode.

Filter filters the incoming elements using a predicate.

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

Item is the PriorityQueue item.

Map takes one element and produces one element.

PassThrough produces the received element as is.

SlidingWindow assigns elements to windows of fixed length configured by the window size parameter.

Throttler limits the throughput to a specific number of elements per time unit.

TumblingWindow assigns each element to a window of a specified window size.

FilterFunc is a filter predicate function.

FlatMapFunc is a FlatMap transformation function.

MapFunc is a Map transformation function.

PriorityQueue implements the heap.Interface.

ThrottleMode defines the Throttler behavior on buffer overflow.