Showing 1-20 of 316 packages
TypeScript definitions for rx-lite-backpressure
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
throttle a stream with backpressure
A comprehensive collection of helper methods for WebStreams with built-in backpressure support, inspired by ReactiveExtensions
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
Lightweight library with backpressure functions for composing asynchronous and event-based operations in JavaScript
Pull-based async pipelines with composable operators and built-in 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
Write to streams, respecting backpressure
An alternative to fs.createWriteStream. Don't handle backpressure, but it's faster and has some other features.
Lightweight older browser compatible library with backpressure functions for composing asynchronous and event-based operations in JavaScript
[](https://coveralls.io/github/rijs/backpressure?branch=master) [](https://travis-ci.org/ri
Filesystem-buffered, passthrough stream that buffers indefinitely rather than propagate backpressure from downstream consumers.
Simple wrapper to allow backpressure-aware Transform streams
A node.js version of unix's `tail -f` command
Mqtt with backpressure support
An RX library to manage the number the items in a queue using backpressure