Skip to content

Pipe<I, O>

typedefPipe<I, O>=Rill<O>Function(Rill<I>)

A function that transforms a Rill<I> into a Rill<O>.

Pipes are plain functions and compose with Rill.through:

dart
Pipe<int, String> stringify = (s) => s.map((n) => n.toString());
source.through(stringify);