Toolkit of 1→N stream combinators: broadcast, route, filter — Node Streams and Web Streams, with proper backpressure handling.
A query library for ECMAScript AST using a CSS selector like query language.
Node.js Streams, a user-land copy of the stream library from Node.js
Check if something is a Node.js stream
Get a stream as a string, Buffer, ArrayBuffer or array
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.
Call a callback when a readable/writable/duplex stream has completed or failed.
Toggle the CLI cursor
destroy a stream if possible
Get and validate the raw body of a readable stream.
Streaming data for JavaScript
Selectors decision tree - choose matching selectors, fast
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
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.
A streaming way to send data to a Node.js Worker Thread
A stream that emits multiple other streams one after another.
minimal implementation of a PassThrough stream
the stream module from node core for browsers
Merge multiple streams into a unified stream
Converts a Web-API readable-stream into a Node.js readable-stream.
An iteration of the Node.js core streams with a series of improvements
Returns the next buffer/object in a stream's readable queue
Streaming HTML parser with scripting support.
The string_decoder module from Node core
Combine messages from multiple Eventide streams into an aggregate stream
XSTREAM combines the X25519 Elliptic Curve Diffie-Hellman function" "with HKDF and the STREAM construction for streaming authenticated" "encryption. The result is an easy-to-use public key cryptosystem.
Fluentd output plugin which detects exception stack traces in a stream of JSON log messages and combines all single-line messages that belong to the same stack trace into one multi-line message. This is an official Google Ruby gem.
Fluentd output plugin which detects exception stack traces in a stream of JSON log messages and combines all single-line messages that belong to the same stack trace into one multi-line message. This is Not an official Google Ruby gem. Added Multiworker to true
O2 Labs has exposed the power of #blue to developers via a simple REST & JSON based API, combined with oAuth2 to developers who can create new ways for users to manage their texts and add combine the ubiquity of SMS with their applications, users simply grant an application access to their messages stream or just certain messages.
Fluentd output plugin which detects exception stack traces in a stream of JSON log messages and combines all single-line messages that belong to the same stack trace into one multi-line message. This is Not an official Google Ruby gem. Added Multiworker to true
Fluentd output plugin which detects exception stack traces in a stream of JSON log messages and combines all single-line messages that belong to the same stack trace into one multi-line message. This is an official Google Ruby gem.
Fluentd output plugin which detects exception stack traces in a stream of JSON log messages and combines all single-line messages that belong to the same stack trace into one multi-line message. This is an official Google Ruby gem.
Fluentd output plugin which detects ft membership specific exception stack traces in a stream of JSON log messages and combines all single-line messages that belong to the same stack trace into one multi-line message. This is an adaption of an official Google Ruby gem.
Fluentd output plugin which detects ft membership specific exception stack traces in a stream of JSON log messages and combines all single-line messages that belong to the same stack trace into one multi-line message. This is an adaption of an official Google Ruby gem.
Cognitive binding engine — combines disparate cognitive streams (emotional, perceptual, memorial, predictive) into unified coherent representations for brain-modeled agentic AI
Reads the interface execution kinesis stream for NT2. Then it uses that execution info combined with information from VINE Services to determine if this is an error state. If it is, it sends a message to Einstein. It also clears Einstein alarms related to tracked errors. State is not tracked between runs, so if the job fails it won't manage previously created errors.