Settings View Source API Reference strom v0.8.4

Runs a set of components and is a component itself, meaning that a composite has the same interface - it accepts flow as input and returns a modified flow.

DSL for building components

Generic functionality used by Strom.Mixer and Strom.Splitter.

Mix several streams into one. Use Strom.GenMix under the hood

Renames streams in flow.

Runs a given steam and call origin on each even in stream. By default it runs the stream asynchronously (in Task.async). One can pass true a the third argument to the Sink.new/3 function to run a stream synchronously.

Produces stream of events.

Split a stream into several streams by applying given functions on events

Transforms a stream or several streams. It works as Stream.map/2 or Stream.transform/3.