Callbag operator that applies a transformation on data passing through it
callbag map+fromPromise+flatten
A tiny but capable push & pull stream library for TypeScript and Flow
Utility function for plugging callbags together in chain
Emits the values emitted by the source Callbag until a notifier Callbag emits a value
👜 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.
👜 Callbag listenable source which emits value describing time progress (number between 0 an 1) since the subscription (using requestAnimationFrame) - useful for animations.
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 milliseconds elapsed since the subscription (using requestAnimationFrame) - useful for animations.
👜 Use callbag as React hook.
Callbag operator that flattens a higher-order callbag source
Callbag factory that merges data from multiple callbag sources
Callbag operator that changes data passing through it to a fixed value
👜 Callbag source factory that emits values specified as arguments.
Callbag operator that maps over values that satisfies a predicate. AKA filterMap
Callbag sink that consume both pullable and listenable sources
Callbag operator that conditionally lets data pass through
Creates a new Callbag given an optional producer
A callbag sink (listener) that connects an Observer a-la RxJS.
Callbag factory that concatenates data from multiple callbag sources
Convert an observable to a callbag listenable source