Compose a Node stream at runtime with conditional logic.
Docker Remote API module.
No description provided.
A CSS-inspired language to select, sequence, and compose DOM events.
Node.js Streams, a user-land copy of the stream library from Node.js
Manage docker-compose from Node.js
Check if something is a Node.js stream
compose Koa middleware
Get a stream as a string, Buffer, ArrayBuffer or array
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.
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
Merge multiple streams into a unified stream
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
An iteration of the Node.js core streams with a series of improvements
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.
TypeScript definitions for koa-compose
Pipelines for streaming large collections with composition inspired by Elixir pipes.
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.
Wrapper to read gz/gzip files composed of multiple gz streams (eg, made by doing a cat to join some gz files in a bigger one.)
airb is an open-source CLI programming agent that helps developers build software using modern LLMs (OpenAI, Anthropic, Gemini). Built on a clean, composable architecture inspired by Stafford Beer's Viable System Model, it features streaming responses, structured tool calling, built-in file operations, and optional web-based observability. Designed for hackability with small objects, clear seams, and UNIXy ergonomics.
Rubagent is a lightweight Ruby framework for building modular, composable AI agents that can interact with LLMs (like OpenAI), tools, and external APIs. It provides a flexible architecture for defining agents, managing prompts, and orchestrating multi-step workflows using functional patterns. Features: - Streamed LLM responses (OpenAI, etc.) - Plug-and-play agent design - Shared context and memory flow - Support for custom tools and HTTP integrations - Built-in dry-rb and Zeitwerk compatibility
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.
A pure-Ruby, zero-dependency implementation of the Vercel AI SDK "Data Stream Protocol" (UI Message Stream Protocol) — the Server-Sent-Events wire format that drives the AI SDK's useChat / useCompletion / useObject frontend hooks. The protocol is language-agnostic by design, but Ruby had no implementation; ai_stream lets a Rails/Rack backend stream text, reasoning, tool calls, sources, files, and custom data parts to a Vercel-AI-SDK frontend with the exact frames it expects. Provider-agnostic: it composes with ruby_llm, ruby-openai, or any token source instead of competing with them.
No description provided.
No description provided.
No description provided.
No description provided.
No description provided.