🎩 Most advanced high level Node.js Kafka client

Tool for creating efficient data pipelines in a JavaScript environment

Type-safe object streams with seamless support for backpressure, ending, and error handling

A streaming and non-blocking API for reading and processing DICOM data

Asynchronous uni-directional channels in node using async iteration.

Pipe nodejs streams into an async.queue for parallelisation, get backpressure when the queue is full.

A lifo job queue to provide back pressure and load shedding

Promise Semaphore for Node.js projects, inspired by the RAII idiom. Offering backpressure control for enhanced efficiency, utilizing a communicative API that signals availability. Additionally, it features a modern API and incorporates mechanisms for graceful termination and error handling.

Make Rx.js to relax a bit

A modern weighted promise semaphore for Node.js projects, ideal for managing workloads with varying processing requirements. It allows limiting the total weight of concurrently executing jobs, ensuring efficient resource utilization. Offering backpressure control for enhanced efficiency, utilizing a communicative API that signals availability.

Operation debouncer utility

An efficient Promise lock for Node.js projects, ensuring mutually exclusive execution of asynchronous tasks. Key features include a backpressure indicator and the ability to gracefully await the completion of all currently executing or pending tasks, making it ideal for robust production applications requiring smooth teardown.

A modern Promise rate-limiter for Node.js projects, implementing a fixed-window throttling policy. It restricts the number of tasks that can start execution within distinct, non-overlapping time windows. The API provides backpressure control by signaling availability, for enhanced efficiency.