Search results
11 packages found
Sort by: Default
- Default
- Most downloaded this week
- Most downloaded this month
- Most dependents
- Recently published
Set of classes used for async prefetching with backpressure (IterableMapper) and async flushing with backpressure (IterableQueueMapper, IterableQueueMapperSimple)
- p-map
- p-map-iterable
- blocking-queue
- iterable-queue
- mapping
- iterable
- queue
- async
- promise
- back-pressure
- flow-control
- AsyncIterable
- AsyncIterator
Node stream multiplexing with back-pressure on each stream
Streaming message queue with pub-sub, work queues, wildcards and back-pressure. Just Node and a filesystem required.
throttle a stream with backpressure
make a stream observable without losing back-pressure control
Pipe Node.js streams over WebSockets (with back-pressure!).
Pub-sub and work queue service on Primus or TCP. Supports wildcards, streams and back-pressure. Just Node and a filesystem required.
Access control for mqlobber message queues
Node streams2 over Primus: added back-pressure!
Pipe Node.js streams over WebSockets (with back-pressure!).
Wrapper for `Duplex` stream objects to ensure they respect back-pressure