Convert a synchronous pullable source into an array
A tiny but capable push & pull stream library for TypeScript and Flow
A standard for JS callbacks
Callbag factory that merges data from multiple callbag sources
Callbag factory that combines data from multiple callbag sources
Utility function for plugging callbags together in chain
Callbag operator that applies a transformation on data passing through it
👜 Callbag source factory that emits values specified as arguments.
Callbag factory that concatenates data from multiple callbag sources
Callbag operator that broadcasts a single source to multiple sinks
Creates a new Callbag given an optional producer
Convert an observable to a callbag listenable source
A callbag sink (listener) that connects an Observer a-la RxJS.
Callbag sink that consume both pullable and listenable sources
A callbag listener sink which is also a listenable source
Callbag operator that conditionally lets data pass through
Emits the values emitted by the source Callbag until a notifier Callbag emits a value
👜 Callbag which creates a source from a given factory when sink subscribes.
debounce operator for callbag
👜 Callbag operator which performs a side effect for every upwards emission (from sink to source), but other than that it acts as noop.
👜 Callbag operator which converts source to a promise containing last emitted value.
👜 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 which resubscribes to the source given amount of times.