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
Basic cache object for storing key-value pairs.
A tiny but capable push & pull stream library for TypeScript and Flow
Map `visit` over an array of objects.
👜 Callbag operator which shares input stream between subscribers and emits last emitted value upon subscription.
Merge old source map and new source map in multi-transform flow
👜 Callbag operator that maps to inner source, subscribe and emit in order.
Returns an array of mapped values from an array or object.
A standard for JS callbacks
Emits the values emitted by the source Callbag until a notifier Callbag emits a value
Callbag operator that flattens a higher-order callbag source
Fixes stack traces for files with source maps
👜 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 operator that conditionally lets data pass through
Faster, node.js focused alternative to JavaScript's native array map.
👜 Callbag listenable source which emits value describing time progress (number between 0 an 1) since the subscription (using requestAnimationFrame) - useful for animations.
👜 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
Visit a method over the items in an object, or map visit over the objects in an array.
A callbag sink (listener) that connects an Observer a-la RxJS.