Rust-inspired fallible async streams — Stream, Sink, Channel with Result-based pull protocol

Get a stream as a string, Buffer, ArrayBuffer or array

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

Async streams that keep flowing, even when things go wrong

Framework-agnostic RxJS operators that bridge async streams with UI state primitives (React Hooks, Angular Signals, Vue Refs) — declarative loading, error and success feedback with zero boilerplate.

Tiny utilities for inserting transformation logic into Node.js stream and Web Streams pipelines

Web Streams, based on the WHATWG spec reference implementation

A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.

A pair of connected async streams where one acts as reader and the other as writer, and reverse() swaps their roles

Merge multiple streams into a unified stream

Like `through` for async streams.

Open Node Streams on demand.

Allows libraries to handle various caller provided asynchronous functions uniformly. Maps promises, observables, child processes and streams, and callbacks to callback style.

Settle an async function.

A library that makes it easier to work with Streams in the browser.

A Promise-based interface into processes created by child_process.spawn

Minimal async jobs utility library, with streams support

Map over promises concurrently

An iteration of the Node.js core streams with a series of improvements

Combines array of streams into one Readable stream in strict order.