Search results
55 packages found
Safely creates an array of elements inside a stream. It prevents [backpressuring in streams](https://nodejs.org/es/docs/guides/backpressuring-in-streams/) by waiting the drain after reaching a limit of batches built
Visualizes a stream in the browser.
RxJS observables with back-pressure
Node.js kafka client, consumer, producer polite out of the box
Provides a backpressure management hystrix command partially based on too-busy module logic and utilizing hystrix metrics accumulation and circuit breaking
Producer-consumer implementation based on nodejs stream
A node duplex stream used for caching stream information to the file system while processing. This module is very helpful when large amounts of data need to be processed over the network, while ensuring that the connection is not open for a long period o
Concurrent control of functions on a per-pool basis with async/await
An influx broadcaster supporting multiple transmission protocols and applies backpressure to reduce chattiness.
Mqtt with backpressure support
A high performance Node.js Redis client with redis ACL functionalities
Type-safe object streams with seamless support for backpressure, ending, and error handling
Pipe Node.js streams over WebSockets (with back-pressure!).
Pipe Node.js streams over WebSockets (with back-pressure!).
a lightweight wrapper around mrraney's redis lib to make it easier to adapt to backpressure