Read binary streams in chunks, on demand, with promises.
Read an HTML5 File object (from e.g. HTML5 drag and drops) as a pull stream source.
pull-stream source that produces data on state transitions
pull-stream source for ES6 iterables
Check if something is a Node.js stream
Node.js Streams, a user-land copy of the stream library from Node.js
Get a stream as a string, Buffer, ArrayBuffer or array
Read an HTML5 File object (from e.g. HTML5 drag and drops) as a pull stream source.
Toggle the CLI cursor
destroy a stream if possible
Get and validate the raw body of a readable stream.
a pull-stream source that does nothing until you abort it.
function as a stream source
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.
A stream that emits multiple other streams one after another.
Create a stream source from a Chrome event emitter.
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
Create a stream that emits events from multiple other streams
The string_decoder module from Node core
Merge multiple streams into a unified stream
Returns the next buffer/object in a stream's readable queue
a streaming CRC32 checksumer
Clone a Node.js HTTP response stream
lib for storage stream programing
Jetstream source for the Yellowstone Vixen
An ETL library for Ruby that performs the basic actions of ETL: extract, transform, and load. Easily extensible.
Facade adapting apis to activity streams spec
Defines a DSL to allow stream processing from various sources for output to various sinks
An open source Rails 8+ engine built on `layered-ui-rails` that provides a multi-provider AI assistant with streaming responses and a full conversation UI.
This gem makes it possible to build filters or pipelines for processing data into or out of streams of bytes while maintaining compatibility with native Ruby IO classes. Ruby IO classes may function as both sources and sinks, or entirely new IO implementations may be created.
Materialize is a streaming database for real-time applications. Materialize accepts input data from a variety of streaming sources (e.g. Kafka) and files (e.g. CSVs), and lets you query them using SQL.
Ruby bindings for archive_r, a libarchive-based library for processing many archive formats. It streams entry data directly from the source to recursively read nested archives without extracting to temporary files or loading large in-memory buffers.
Hot Potato is an open source real-time processing framework written in Ruby. Originally designed to process the Twitter firehose at 3,000+ tweets per second, it has been extended to support any type of streaming data as input or output to the framework. The framework excels with applications such as, social media analysis, log processing, fraud prevention, spam detection, instant messaging, and many others that include the processing of streaming data.
Kaitai Struct is a declarative language used for describe various binary data structures, laid out in files or in memory: i.e. binary file formats, network stream packet formats, etc. The main idea is that a particular format is described in Kaitai Struct language (.ksy file) and then can be compiled with ksc into source files in one of the supported programming languages. These modules will include a generated code for a parser that can read described data structure from a file / stream and give access to it in a nice, easy-to-comprehend API. This package provides small runtime library used by code generated by Kaitai Struct compiler.
A configurable lint engine for SAS source files. Walks the token stream produced by the `sas-lexer` gem and applies a set of pluggable rules covering structural defects (malformed `if` conditions, identical `then`/`else` branches, unreachable inner branches), cosmetic issues (trailing whitespace, tab expansion, line endings, encoding gremlins), and source-header conventions. Includes a `bin/sas_lint` CLI and YAML-based config.
Unified C-extension gem for zstd, lz4, and brotli compression. One-shot, streaming, IO wrappers, dictionary support. Fiber-friendly: cooperates with Fiber::Scheduler (async, falcon) so CPU-heavy compression never blocks the event loop. Ships vendored sources — no system libraries required.
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.
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.