Sub modules

A source that never yields a value

Iterate the stream, flowing values downstream to the reducer, which aggregates a result value.

Iterate the stream, flowing values downstream to the reducer, which aggregates a result value.

Iterate the stream, flowing values downstream to the reducer, which aggregates a result value.

Iterate the stream, flowing values downstream to the reducer, which aggregates a result value.

Transform with a transducer

Functor map

Monad bind

Monad bind

Filter values. Yielding downstream when true

Filter values. Yielding downstream when true

Applicative apply

Concatenate two sources into a single source.

The value streams are both merged into a new stream. Values are yielded as they become available.

Zip two sources into one

Zip three sources into one

Zip three sources into one

Skip items in the source

Limit the number of items processed

Fold the values flowing through. A value is only yielded downstream upon completion of the stream.

Fold the values flowing through. Values are yielded downstream when either the schedule expires, or the source completes.

Fold the values flowing through. Values are yielded downstream when either the predicate returns false, or the source completes.

Fold the values flowing through. Values are yielded downstream when either the predicate returns true, or the source completes.

Fold the values flowing through. Values are yielded downstream when either the schedule expires, the predicate returns false, or the source completes.

Fold the values flowing through. Values are yielded downstream when either the schedule expires, the predicate returns true, or the source completes.

Convert Source to a ProducerT pipe component

Convert Source to a Producer pipe component

Functor map

Monad bind

Concatenate two sources into a single source.

The value streams are both merged into a new stream. Values are yielded as they become available.

Sequentially compose two actions, discarding any value produced by the first, like sequencing operators (such as the semicolon) in C#.

Sequentially compose two actions, discarding any value produced by the first, like sequencing operators (such as the semicolon) in C#.

Sequentially compose two actions. The second action is a unit-returning action, so the result of the first action is propagated.

Sequentially compose two actions. The second action is a unit-returning action, so the result of the first action is propagated.

Downcast

Force iteration of the stream, yielding a unit M structure.

The expectation is that the stream uses IO for side effects, so this makes them to happen.

Force iteration of the stream, yielding a unit M structure.

The expectation is that the stream uses IO for side effects, so this makes them to happen.

Force iteration of the stream, yielding the last structure processed

Force iteration of the stream, yielding the last structure processed

Force iteration of the stream and collect all the values into a Seq.

Force iteration of the stream and collect all the values into a Seq.

Empty source

This is a 'void' source, it yields zero values.

Lift a pure value into the source

This is a singleton/unit source, it yields exactly one value.

Lift a pure value into the source and yield it for infinity

This is an infinite source, it repeatedly yields a value.

Make a System.Threading.Channels.Channel into a source of values

Make an IEnumerable into a source of values

Make an IAsyncEnumerable into a source of values

Make an IObservable into a source of values

Merge sources into a single source

Merge sources into a single source

Zip two sources into one

Zip three sources into one

Zip three sources into one