Intuitive node streams in typescript.
Get a stream as a string, Buffer, ArrayBuffer or array
WebSocket protocol handler with pluggable I/O
This is lightweight memory stream module for node.js.
Node.js Streams, a user-land copy of the stream library from Node.js
Check if something is a Node.js stream
node.js library for reading and extraction of ZIP archives
Toggle the CLI cursor
tar-stream is a streaming tar parser and generator and nothing else. It operates purely using streams which means you can easily extract/parse tarballs without ever hitting the file system.
destroy a stream if possible
Call a callback when a readable/writable/duplex stream has completed or failed.
A streaming way to send data to a Node.js Worker Thread
Get and validate the raw body of a readable stream.
Returns the next buffer/object in a stream's readable queue
A stream that emits multiple other streams one after another.
Streaming data for JavaScript
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
Merge multiple streams into a unified stream
Streaming HTML parser with scripting support.
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.
minimal implementation of a PassThrough stream
writable stream that concatenates strings or binary data and calls a callback with the result
the stream module from node core for browsers
Stream selection for airio
Streaming anomaly detection toolkit — Random Cut Forest, per-feature drift, streaming sketches, SOC triage, hot-path ingress. Facade re-export of anomstream-core / anomstream-triage / anomstream-hotpath.
Core streaming anomaly detectors + companion primitives (Random Cut Forest, per-feature EWMA / CUSUM, drift detectors, streaming stats) — part of the anomstream toolkit
High-cadence ingress primitives (UpdateSampler, PrefixRateCap, bounded MPSC channel) for eBPF-style classifier/updater thread splits on top of anomstream-core
SOC-opinionated triage layer (Platt calibration, SAGE attribution, alert clustering, feedback, audit) on top of anomstream-core
IntoAsyncRead on steriods
Async JSON stream reader for selective parsing of large payloads
Streaming bioinformatics data types
minimal stream for reading from an existing vector by reference. It is designed for scenarios where efficient deserialization from a byte vector is required.
The Cognitive Stream Protocol - Standardized streaming format for AI reasoning visualization.
Lean-backed fixed-dimension streaming covariance and Ledoit-Wolf shrinkage
HidApi driver for Elgato Stream Deck devices
Catches stdout and stderr for ruby blocks.
Pure Ruby implementation of the MQTT 3.1.1 and 5.0 packet codec: encode, decode, VBI, properties, reason codes. Protocol::MQTT::Connection wraps an IO::Stream to read and write packets. No I/O beyond IO::Stream.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.