wonka
A tiny but capable push & pull stream library for TypeScript and Flow
callbag-take-while
👜 Callbag operator which emits values emitted by the source as long as each value satisfies the given predicate, and then completes as soon as predicate is not satisfied.
callbag-concat-with
👜 Callbag operator that emits items given it as arguments after it finishes emitting items emitted by source.