A library for creating Readable, Writable and Transform stream which adopt two major tools in async world - Stream and Promise - with declarative programming approach.
Type-safe stream operators like filter, map, reduce, and forEach
Reactive dataflow processing.
Transforms logical assignment operators into short-circuited assignments
Allow parsing of the logical assignment operators
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.
Toggle the CLI cursor
Call a callback when a readable/writable/duplex stream has completed or failed.
destroy a stream if possible
Get and validate the raw body of a readable stream.
A streaming way to send data to a Node.js Worker Thread
A stream that emits multiple other streams one after another.
Shared RxJS Operators for NgRx libraries
Streaming data for JavaScript
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
Merge multiple streams into a unified stream
Powerful Reactive Framework based on EventEmitter, Signals, and Object Stream Operators
An iteration of the Node.js core streams with a series of improvements
Returns the next buffer/object in a stream's readable queue
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 collection of selected rxjs operators for rust standard Stream
Stream combinators with ordering guarantees for async Rust
A little stream of failible operations
Extend Turbo Streams with Custom Turbo Stream Actions or CableReady operations
This gem is a logstash plugin required to be installed on top of the Logstash core pipeline using $LS_HOME/bin/plugin install gemname. This gem is not a stand-alone program
Ciphr is a CLI tool for performing and composing encoding, decoding, encryption, decryption, hashing, and other various operations on streams of data. It takes provided data, file data, or data from stdin, and executes a pipeline of functions on the data stream, writing the resulting data to stdout. It was designed primarily for use in the information security domain, mostly for quick or casual data manipulation for forensics, penetration testing, or capture-the-flag events; it likely could have other unforseen uses, but should be presumed to be an experimental toy as no effort was made to make included cryptographic functions robust against attacks (timing attacks, etc), and it is recommended not to use any included functions in any on-line security mechanisms.
If you have multiple applications that need to perform actions as operations occur, `meeseeker` will allow your apps to each perform actions for specific operations without each app having to streaming the entire blockchain.
EnumerableFu extends Enumerable with "lazy" versions of various operations, allowing streamed processing of large (or even infinite) collections.
Enumerating extends Enumerable with "lazy" versions of various operations, allowing streamed processing of large (or even infinite) collections. Even in Ruby 1.8.x.
A Ruby library for text classification featuring Naive Bayes, LSI (Latent Semantic Indexing), Logistic Regression, and k-Nearest Neighbors classifiers. Includes TF-IDF vectorization, streaming/incremental training, pluggable persistence backends, thread safety, and a native C extension for fast LSI operations.
A Ruby FFI binding library for libogg, providing OGG container format stream operations (page read/write, packet assembly/disassembly).
Automatically intercept and log LLM requests from Ruby applications. Supports OpenAI, official Anthropic gem, ruby-anthropic gem, and other Faraday-based libraries. Features dual interceptor architecture, streaming support, thread-safe operation, and automatic duplicate request prevention.
EXPERIMENTAL. A form of data-flow programming based loosely on Kahn Process Networks. Will allow for setting up operational components that can be pipelined together in a graph. Assumes all components (nodes) are 'online' algorithms with more or less steady-state resource utilization for continuous streams of data.
A small stream with a bit of state flowing through it. Rivulet gives Ruby a vocabulary for sliding window operations — the grow-shrink-emit pattern that Enumerable never named.
No description provided.
No description provided.
No description provided.
No description provided.