Set of classes used for async prefetching with backpressure (IterableMapper) and async flushing with backpressure (IterableQueueMapper, IterableQueueMapperSimple)
Creates a prefetched async iterable
Multipart and Tar utilities for the Web Streams API
A shim for the setImmediate efficient script yielding API
Map over promises concurrently
async/await simple priority queues
The Interactive Extensions for JavaScript
Queueing jobs in Postgres from Node.js like a boss
Invokes the passed function for each item in an iterable
The Interactive Extensions for JavaScript
A simple tool to keep requests to be executed in order.
Promised out of order transform.
Convert Node.js streams to streaming iterables
`Promise.all` and `Promise.allSettled` with concurrency option and async iterable result
The smallest and simplest JavaScript priority queue
Calls async iterator next using a callback format
Iterable wrapper that add methods to read ahead or behind current item.
Convert a string/promise/array/iterable/asynciterable/buffer/typedarray/arraybuffer/object into a stream
type AnyIterable<T>
Counts the number of items in an async iterable
A queue implementation that can be iterated over
Run promise-returning & async functions concurrently with optional limited concurrency
Task and Message Queues with Multiple Providers
The Interactive Extensions for JavaScript