A pure-callbag-operator implementation of switch-map (not exactly flat-map) for callbags 👜
A pure-callbag-operator implementation of flat-map for callbags 👜 (MOVED TO callbag-switch-map-operator)
Callbag operator that applies a transformation on data passing through it
Utility function for plugging callbags together in chain
A tiny but capable push & pull stream library for TypeScript and Flow
Emits the values emitted by the source Callbag until a notifier Callbag emits a value
Callbag operator that flattens a higher-order callbag source
👜 Callbag operator which shares input stream between subscribers and emits last emitted value upon subscription.
👜 Callbag operator that maps to inner source, subscribe and emit in order.
A standard for JS callbacks
👜 Callbag operator that maps to inner source and ignores other values until that source completes.
👜 Callbag operator which errors if source does not emit before specified duration.
👜 Callbag listenable source which emits value describing time progress (number between 0 an 1) since the subscription (using requestAnimationFrame) - useful for animations.
Callbag operator that conditionally lets data pass through
👜 Callbag listenable source which emits milliseconds elapsed since the subscription (using requestAnimationFrame) - useful for animations.
A JavaScript (JS) Map or Similar object polyfill if Map is not available.
A callbag listener sink which is also a listenable source
Basic cache object for storing key-value pairs.
A callbag sink (listener) that connects an Observer a-la RxJS.
👜 Callbag operator that emits items given it as arguments after it finishes emitting items emitted by source.
👜 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 operator that limits the total amount of data sent through
Callbag operator that broadcasts a single source to multiple sinks
Fast line to line SourceMap generator.