Get a stream as a string, Buffer, ArrayBuffer or array
Web Streams, based on the WHATWG spec reference implementation
An implementation of window.fetch in Node.js using Minipass streams
An iteration of the Node.js core streams with a series of improvements
Merge multiple streams into a unified stream
A small fast zlib stream built on [minipass](http://npm.im/minipass) and Node.js's zlib binding.
The string_decoder module from Node core
Turn a readable stream into multiple readable streamx streams
Streams for reading/writing messages
Open Node Streams on demand.
A library that makes it easier to work with Streams in the browser.
TypeScript definitions for ssh2-streams
Node and Bun local Prisma Streams runtime for trusted development workflows.
Tiny utilities for inserting transformation logic into Node.js stream and Web Streams pipelines
Combines array of streams into one Readable stream in strict order.
Streams for reading Gherkin parser output
Combine an array of streams into a single duplex stream using pump and duplexify
Stream extension for Verdaccio
construct pipes of streams of events
abstract base class for crypto-streams
urx-react is an urx extension that builds React components from urx systems.
Node.js Streams, a user-land copy of the stream library from Node.js
a JSON logging library for node.js services
A stream that emits multiple other streams one after another.
Typed reactive streams DSL for atomr — Source / Flow / Sink, junctions, framing, kill switches, hubs, stream refs.
Real-world I/O Source/Sink adapters for atomr-streams — HTTP polling and WebSocket connectors behind feature flags.
atomr-streams integration for atomr-infer; re-exports the atomr-accel-patterns blueprints (DynamicBatchingServer, InferenceCascade, ModelReplicaPool, FairShareScheduler, ModelHotSwapServer, SpeculativeDecoder, MoeRouter).
FIX session-layer for atomr — logon/heartbeat/sequence/resend/gap-fill session FSM over atomr-streams Tcp + Framing, with a pluggable persistent sequence store.
Native Rust runtime for actor-based concurrent and distributed systems. Umbrella crate — pull in subsystems via feature flags.
Membership, gossip, reachability, vector clocks, and split-brain resolvers for atomr clusters.
Adaptive load balancing using cluster-wide metrics for atomr.
Sharded entities for atomr — allocation strategies, rebalance, three-phase handoff, remember-entities.
Distributed pub/sub, cluster singleton, and cluster client patterns for atomr.
Layered HOCON-style configuration for atomr — `include`, `${path}` substitution, `${?ENV}`, dotted keys, arrays.
Lease-based coordination primitives for atomr.
Actors, supervision, dispatch, mailboxes, scheduler, FSM, event stream, and coordinated shutdown — the core of the atomr actor runtime.