Modern stream composer
api.video media stream composer
Reactive stream composer for React application
Compose render prop components
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
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.
Call a callback when a readable/writable/duplex stream has completed or failed.
destroy a stream if possible
A streaming way to send data to a Node.js Worker Thread
Get and validate the raw body of a readable stream.
Returns the next buffer/object in a stream's readable queue
Streaming data for JavaScript
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 stream that emits multiple other streams one after another.
A utility for composing ESLint rules from other ESLint rules
minimal implementation of a PassThrough stream
Merge multiple streams into a unified stream
writable stream that concatenates strings or binary data and calls a callback with the result
the stream module from node core for browsers
An iteration of the Node.js core streams with a series of improvements
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.