TypeScript definitions for rx-lite-backpressure

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

Set of classes used for async prefetching with backpressure (IterableMapper) and async flushing with backpressure (IterableQueueMapper, IterableQueueMapperSimple)

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

A WebSocketStream polyfill: a plain WebSocket wrapped as { readable, writable } streams with backpressure

Utility for handling backpressure in transforms automatically

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

throttle a stream with backpressure

Redis Streams plugin for NestJS RedisX with consumer groups, dead-letter queues, and backpressure

A comprehensive collection of helper methods for WebStreams with built-in backpressure support, inspired by ReactiveExtensions

Toolkit of 1→N stream combinators: broadcast, route, filter — Node Streams and Web Streams, with proper backpressure handling.

Typed event streaming with backpressure for Centient packages

rdsh wire protocol: framing, multiplexing, heartbeat, backpressure

Write to streams, respecting backpressure

An alternative to fs.createWriteStream. Don't handle backpressure, but it's faster and has some other features.

Bridge RxJS and Effect-TS — turn an Observable into a typed Effect Stream with backpressure and proper interruption.

Composable async iterable transforms: map, filter, batch, window, buffered and concurrent processing with backpressure.

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

Extensible backpressure-aware streaming parsers, transformers, and projections for tuil.

A modern Promise-semaphore for Node.js projects, enabling users to limit the number of concurrently executing promises. Offering backpressure control for enhanced efficiency, utilizing a communicative API that signals availability, promoting a just-in-tim