@shutterstock/p-map-iterable

Set of classes used for async prefetching with backpressure (IterableMapper) and async flushing with backpressure (IterableQueueMapper, IterableQueueMapperSimple)

v1.1.2 URL: https://unpkg.com/@shutterstock/p-map-iterable@1.1.2/dist/src/index.js

Open Browse Files

p-map p-map-iterable blocking-queue iterable-queue mapping iterable queue async promise back-pressure flow-control AsyncIterable AsyncIterator

@alexanderfedin/async-queue

TypeScript async producer-consumer queue with backpressure control, similar to Go channels or .NET Channel<T>

v1.1.0 URL: https://unpkg.com/@alexanderfedin/async-queue@1.1.0/dist/index.js

Open Browse Files

async queue backpressure producer-consumer channel concurrent push-pull flow-control promise async-await blocking-queue bounded-queue async-iterator async-iterable async-generator typescript circular-buffer high-performance

@shutterstock/chunker

Calls a callback before size would be exceeded or when count limit is reached

v1.1.0 URL: https://unpkg.com/@shutterstock/chunker@1.1.0/dist/src/index.js

Open Browse Files

chunk batch buffer blocking-queue size-limit kinesis async promise