TypeScript definitions for through
Call a callback when a readable/writable/duplex stream has completed or failed.
Buffer and transform the n first bytes of a stream
Next tick shim that prefers process.nextTick over queueMicrotask for compat
Allows libraries to handle various caller provided asynchronous functions uniformly. Maps promises, observables, child processes and streams, and callbacks to callback style.
Node.js Transform and Async interface to convert JSON into CSV.
Get and validate the raw body of a readable stream.
Forward a readable stream to another readable stream or a writable stream to another writable stream
Tiny async queue with concurrency control. Like p-limit or fastq, but smaller and faster.
A streaming way to send data to a Node.js Worker Thread
Multi-strategy job queue with local and BullMQ support
A stream that emits multiple other streams one after another.
Streaming data for JavaScript
A readable async stream which can be iterated over using a for-await-of loop.
Convert streaming iterables to Node.js streams
Merge multiple streams into a unified stream
Postgres query result returned as readable stream
Promise-based queue
An iteration of the Node.js core streams with a series of improvements
A micro-library of stream components for building custom JSON and JSONC processing pipelines with a minimal memory footprint — parse, filter, and transform JSON far larger than available memory with a SAX-inspired token API, on Node.js or Web Streams.
Streaming HTML parser with scripting support.
a through stream that starts paused and resumes on the next tick
LRU Queue
minimal implementation of a PassThrough stream