Join values from multiple object-mode Readable streams into a single Readable, with proper backpressure handling.

MCP server for Backpressure: connect your AI coding agent to simulate architectures, create boards, and stress-test designs (#444).

Backpressure-aware CSV and NDJSON streams for Minnow queries.

Lightweight older browser compatible library with backpressure functions for composing asynchronous and event-based operations in JavaScript

Chain functions, generators, Node streams, and Web streams into a pipeline with backpressure support.

Adaptive concurrency, bounded backpressure, and dependency resilience for Node.js.

ZipLogger Node.js SDK — core client plus Pino and Winston transports. Batching, retries, backpressure, automatic enrichment.

[](https://coveralls.io/github/rijs/backpressure?branch=master) [](https://travis-ci.org/ri

A transform stream that applies backpressure based on a check function.

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

An efficient Promise lock for Node.js projects, ensuring mutually exclusive execution of asynchronous tasks. Key features include a backpressure indicator, access to the currently executing task promise for smart reuse (useful when launching a duplicate t

Filesystem-buffered, passthrough stream that buffers indefinitely rather than propagate backpressure from downstream consumers.

Generic byte-stream transport abstraction (TCP sockets, DNS, backpressure). No knowledge of TLS or HTTP.

Bridge callback-style producers into async generators with backpressure and cleanup.

Context-aware code retrieval broker MCP server — minimal, ranked, backpressure-enforced results for coding agents

TypeScript async producer-consumer queue with backpressure control, similar to Go channels or .NET Channel<T>

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

Allows a muxrpc source to have normal pull-stream backpressure

An RX library to manage the number the items in a queue using backpressure

A node.js version of unix's `tail -f` command