A Wrapped Transform Stream
Buffers events from a stream until you are ready to handle them.
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
Iterate all the data in a stream
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
Convenience wrapper for ReadableStream, with an API lifted from "from" and "through2"
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.
A stream that emits multiple other streams one after another.
Returns the next buffer/object in a stream's readable queue
Streaming data for JavaScript
Bundled CSS for Stream Chat web SDKs
Merge multiple streams into a unified stream
An iteration of the Node.js core streams with a series of improvements
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
Streaming HTML parser with scripting support.
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
A streaming XML parser which builds objects and passes them to a collecter as they are ready. Based upon Nokogiri SAX parsing functionality.
A gem to generate a MVC scaffold to quickly get started with Turbo Streams. This scaffold builds on top of the existing Rails generatiors to include the model, controller actions, and Turbo ready-views that you need for your model to be streamed when instances are created, updated, and deleted.
SmarterCSV is a high-performance CSV reader and writer for Ruby focused on fastest end-to-end ingestion — not just parsing. It returns ready-to-use hashes with configurable header and value transformations, intelligent defaults, and automatic delimiter discovery. Built for real-world data pipelines, SmarterCSV supports chunked processing for large files, streaming via Enumerable APIs, and C acceleration to optimize the full ingestion path (parsing + hash construction + conversions). Designed to handle messy user-uploaded CSV while remaining easy to integrate with Rails, ActiveRecord imports, Sidekiq jobs, parallel processing, and S3-based workflows.
A production-ready Action Cable subscription adapter that uses MongoDB (via Mongoid) as a durable, cross-process broadcast backend with Change Streams support
SimpleChat is a Rails engine that provides a ready-to-use chat system. It supports chat rooms, members, and real-time messaging leveraging Turbo Streams and Solid Cable for a modern, reactive experience.
RubyPi is a minimal, composable AI agent harness for Ruby. Build production-ready LLM agents and AI agents with a unified provider interface across OpenAI, Anthropic Claude, and Google Gemini, plus first-class support for tool calling (function calling), streaming responses, automatic retries, provider fallback, context compaction, and a think-act-observe agent loop. Anti-framework design — small, idiomatic, and explicit. Ideal for building autonomous AI agents, ReAct agents, tool-using LLM agents, and chatbots in Ruby.
SolidStackWeb is a mountable Rails engine that provides a production-ready operations dashboard for the full Solid Stack. It covers Solid Queue (job browser, failed job retry with inline argument editing, queue pause/resume, recurring tasks, performance stats, CSV export, and alert webhooks), Solid Cache (entry browser, size distribution, 24-hour write timeline, and optional value preview), and Solid Cable (channel browser, per-channel message list, and purge controls). Ships with dark mode, Turbo Stream responses, a JSON metrics endpoint, and no asset pipeline dependency.
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.