wonka
A tiny but capable push & pull stream library for TypeScript and Flow
A tiny but capable push & pull stream library for TypeScript and Flow
A standard for JS callbacks
A callbag sink (listener) that connects an Observer a-la RxJS.
Callbag operator that applies a transformation on data passing through it
Callbag operator that broadcasts a single source to multiple sinks
A callbag listener sink which is also a listenable source
Callbag operator that flattens a higher-order callbag source
Callbag factory that concatenates data from multiple callbag sources
Callbag factory that merges data from multiple callbag sources
Create a callbag listenable source from events on a DOM node
👜 Callbag source factory that emits values specified as arguments.
Callbag source for lazy evaluation
👜 Callbag which creates a source from a given factory when sink subscribes.
👜 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.
👜 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 emits items given it as arguments after it finishes emitting items emitted by source.
Utility function for plugging callbags together in chain
Emits the values emitted by the source Callbag until a notifier Callbag emits a value
Callbag listener sink that gets data from any listenable source