A tiny but capable push & pull stream library for TypeScript and Flow
A callbag sink (listener) that connects an Observer a-la RxJS.
Callbag operator that broadcasts a single source to multiple sinks
Callbag operator that applies a transformation on data passing through it