TypeScript definitions for rx-lite-backpressure

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

Assess your repository's readiness for AI coding agents.

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.

Utility for handling backpressure in transforms automatically

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

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

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

throttle a stream with 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.

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

a lightweight wrapper around mrraney's redis lib to make it easier to adapt to backpressure

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

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

Composable stream primitive with hot/cold semantics, backpressure, and ecosystem adapters

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

Async throttle with cancel/flush, deduplication, backpressure strategies, retry/jitter, and per-task metrics. RxJS-friendly.

Wishtunnel shared utilities: structured logging, WebSocket stream pumping with backpressure, and stream registries.