Convert an iterable or iterator to a callbag pullable source
A tiny but capable push & pull stream library for TypeScript and Flow
Get the first fulfilled promise that satisfies the provided testing function
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
[](http://www.typescriptlang.org/) [](https://www.npmjs.com/package/@n1ru4l/push-pull-async
Extended iterable class, providing lazy array-like methods with automatic async and return/throw forwarding
Callbag operator that applies a transformation on data passing through it
A standard for JS callbacks
👜 Callbag source factory that emits values specified as arguments.
Utility function for plugging callbags together in chain
Callbag factory that merges data from multiple callbag sources
👜 Callbag which creates a source from a given factory when sink subscribes.
Deques are a generalization of stacks and queues
Callbag factory that concatenates data from multiple callbag sources
Emits the values emitted by the source Callbag until a notifier Callbag emits a value
Convert a string/promise/array/iterable/asynciterable/buffer/typedarray/arraybuffer/object into a stream
A callbag sink (listener) that connects an Observer a-la RxJS.
Callbag sink that consume both pullable and listenable sources
Convert an observable to a callbag listenable source
👜 Callbag operator that emits items given it as arguments after it finishes emitting items emitted by source.
Callbag operator that conditionally lets data pass through
👜 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 shares input stream between subscribers and emits last emitted value upon subscription.
👜 Callbag operator which performs a side effect for every upwards emission (from sink to source), but other than that it acts as noop.