mperktold

sounk

Specification for both pull- and push-based data pipelines

callbag-graceful

Callbag operator for graceful error handling

callbag-flat-map-lazy

A callbag operator that maps items to sources and flattens them lazily

callbag-merge-all

Callbag operator that merges all items a source of sources into a single output source

callbag-pull

Callbag operator that pulls a source for a given number of times