@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

bpmux

Node stream multiplexing with back-pressure on each stream

v8.2.1 URL: https://unpkg.com/bpmux@8.2.1/index.js

Open Browse Files

stream back-pressure backpressure high-water mark duplex readable writable multiplex mux demux

mqlobber

Streaming message queue with pub-sub, work queues, wildcards and back-pressure. Just Node and a filesystem required.

v9.0.7 URL: https://unpkg.com/mqlobber@9.0.7/index.js

Open Browse Files

qlobber stream pubsub queue routing back-pressure

ws-streamify

Pipe Node.js streams over WebSockets (with back-pressure!).

v0.1.4 URL: https://unpkg.com/ws-streamify@0.1.4/lib/index.js

Open Browse Files

ws websocket backpressure back-pressure stream

brake

throttle a stream with backpressure

v1.0.1 URL: https://unpkg.com/brake@1.0.1/index.js

Open Browse Files

rate limit stream back-pressure drain pause resume pipe slow buffered