Fan-out the stream to several streams. Each upstream element is emitted to the first available downstream consumer. It will not shut down until the subscriptions for at least two downstream subscribers have been established. A Balance< T> has one In port and 2 or more Out(Int32) ports.

Emits when any of the outputs stops backpressuring; emits the element to the first available output

Backpressures when all of the outputs backpressure

Completes when upstream completes

Cancels when all downstreams cancel

TBD

TBD

Fan-out the stream to several streams emitting each incoming upstream element to all downstream consumers. It will not shut down until the subscriptions for at least two downstream subscribers have been established.

Emits when all of the outputs stops backpressuring and there is an input element available

Backpressures when any of the outputs backpressure

Completes when upstream completes

Cancels when If eagerCancel is enabled: when any downstream cancels; otherwise: when all downstreams cancel

A BroadcastHub is a special streaming hub that is able to broadcast streamed elements to a dynamic set of consumers. It consists of two parts, a Sink< TIn, TMat> and a Source<TOut, TMat>. The Sink< TIn, TMat> broadcasts elements from a producer to the actually live consumers it has. Once the producer has been materialized, the Sink< TIn, TMat> it feeds into returns a materialized value which is the corresponding Source<TOut, TMat>. This Source< TOut, TMat> can be materialized arbitrary many times, where each of the new materializations will receive their elements from the original Sink<TIn, TMat>.

TBD

Takes two streams and outputs one stream formed from the two input streams by first emitting all of the elements from the first stream and then emitting all of the elements from the second stream. A Concat< TIn, TOut> has one multiple In(Int32) ports and one Out port.

Emits when the current stream has an element available; if the current input completes, it tries the next one

Backpressures when downstream backpressures

Completes when all upstreams complete

Cancels when downstream cancels

TBD

A Flow is a set of stream processing steps that has one open input and one open output.

A Flow< TIn, TOut, TMat> is a set of stream processing steps that has one open input and one open output.

TBD

TBD

TBD

TBD

A graph DSL, which defines an API for building complex graphs. Graph definitions are enclosed within a scope of functions defined by user, using a dedicated GraphDsl. Builder< T> helper to connect specific graph stages with each other.

TBD

TBD

TBD

TBD

Interleave represents deterministic merge which takes N elements per input stream, in-order of inputs, emits them downstream and then cycles/"wraps-around" the inputs.

Emits when element is available from current input (depending on phase)

Backpressures when downstream backpressures

Completes when all upstreams complete (eagerComplete=false) or one upstream completes (eagerComplete=true)

Cancels when downstream cancels

Provides JSON framing stages that can separate valid JSON objects from incoming ByteString objects.

Convenience functions for often-encountered purposes like keeping only the left (first) or only the right (second) of two input values.

Merge several streams, taking elements as they arrive from input streams (picking randomly when several have elements ready).

Emits when one of the inputs has an element available

Backpressures when downstream backpressures

Completes when all upstreams complete

Cancels when downstream cancels

Merge several streams, taking elements as they arrive from input streams (picking randomly when several have elements ready).

Emits when one of the inputs has an element available

Backpressures when downstream backpressures

Completes when all upstreams complete

Cancels when downstream cancels

A MergeHub is a special streaming hub that is able to collect streamed elements from a dynamic set of producers. It consists of two parts, a Source< TOut, TMat> and a Sink<TIn, TMat>. The Source< TOut, TMat> streams the element to a consumer from its merged inputs. Once the consumer has been materialized, the Source< TOut, TMat> returns a materialized value which is the corresponding Sink<TIn, TMat>. This Sink< TIn, TMat> can then be materialized arbitrary many times, where each of the new materializations will feed its consumed elements to the original Source<TOut, TMat>.

TBD

Merge several streams, taking elements as they arrive from input streams (picking from preferred when several have elements ready). A MergePreferred< T> has one Out port, one Preferred input port and 0 or more secondary In(Int32) ports.

Emits when one of the inputs has an element available, preferring a specified input if multiple have elements available

Backpressures when downstream backpressures

Completes when all upstreams complete (eagerComplete=false) or one upstream completes (eagerComplete=true)

Cancels when downstream cancels

TBD

Merge two pre-sorted streams such that the resulting stream is sorted.

Emits when both inputs have an element available

Backpressures when downstream backpressures

Completes when all upstreams complete

Cancels when downstream cancels

TBD

TBD

TBD

Takes two streams and passes the first through, the secondary stream is only passed through if the primary stream completes without passing any elements through. When the first element is passed through from the primary the secondary is cancelled. Both incoming streams are materialized when the stage is materialized. On errors the stage is failed regardless of source of the error. '''Emits when''' element is available from primary stream or the primary stream closed without emitting any elements and an element is available from the secondary stream '''Backpressures when''' downstream backpressures '''Completes when''' the primary stream completes after emitting at least one element, when the primary stream completes without emitting and the secondary stream already has completed or when the secondary stream completes '''Cancels when''' downstream cancels

TBD

Fan-out the stream to several streams. emitting an incoming upstream element to one downstream consumer according to the partitioner function applied to the element

Emits when an element is available from the input and the chosen output has demand

Backpressures when the currently chosen output back-pressures

Completes when upstream completes and no output is pending

Cancels when when all downstreams cancel

TBD

TBD

TBD

TBD

TBD

A Sink< TIn, TMat> is a set of stream processing steps that has one open input. Can be used as a ISubscriber

TBD

A Source< TOut, TMat> is a set of stream processing steps that has one open output. It can comprise any number of internal sources and transformations that are wired together, or it can be an "atomic" source, e.g. from a collection or a file. Materialization turns a Source into a Reactive Streams IPublisher (at least conceptually).

TBD

Converters for interacting with the IO streams APIs

A "stream of streams" sub-flow of data elements, e.g. produced by GroupBy. SubFlows cannot contribute to the super-flow’s materialized value since they are materialized later, during the runtime of the flow graph processing.

TBD

TBD

TBD

TBD

TBD

Takes a stream of pair elements and splits each pair to two output streams. An UnZip< T1, T2> has one in port and one left and one right output port.

Emits when all of the outputs stops backpressuring and there is an input element available

Backpressures when any of the outputs backpressures

Completes when upstream completes

Cancels when any downstream cancels

TBD

TBD

TBD

TBD

TBD

TBD

TBD

TBD

TBD

TBD

TBD

TBD

TBD

Combine the elements of 2 streams into a stream of tuples. A Zip< T1, T2> has a left and a right input port and one out port

Emits when all of the inputs has an element available

Backpressures when downstream backpressures

Completes when any upstream completes

Cancels when downstream cancels

TBD

Combine the elements of multiple streams into a stream of sequences. A ZipN< T> has a n input ports and one out port

Emits when all of the inputs has an element available

Backpressures when downstream backpressures

Completes when any upstream completes

Cancels when downstream cancels

TBD

TBD

TBD

TBD

TBD

TBD

TBD

TBD

TBD

TBD

Combine the elements of multiple streams into a stream of sequences using a combiner function. A ZipWithN< TIn, TOut> has a n input ports and one out port

Emits when all of the inputs has an element available

Backpressures when downstream backpressures

Completes when any upstream completes

Cancels when downstream cancels

Represents an accepted incoming TCP connection.

Represents a prospective outgoing TCP connection.

Represents a successful TCP server binding.

Operations offered by Sources and Flows with a free output side: the DSL flows left-to-right only.

Flow with attached input and output, can be executed.

TBD