@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

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

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

centro-js

Pub-sub and work queue service on Primus or TCP. Supports wildcards, streams and back-pressure. Just Node and a filesystem required.

v4.0.0 URL: https://unpkg.com/centro-js@4.0.0/index.js

Open Browse Files

pub-sub queue primus stream back-pressure routing mqlobber qlobber-fsq