Read and write from streams in an asyncronous serial fashion
Async streams that keep flowing, even when things go wrong
Get a stream as a string, Buffer, ArrayBuffer or array
Tiny utilities for inserting transformation logic into Node.js stream and Web Streams pipelines
A modern type-safe stream processing library inspired by JavaScript Generator, Java Stream, and MySQL Index. Supports lazy evaluation, async streams, statistics, and IO-like operations.
Like `through` for async streams.
Web Streams, based on the WHATWG spec reference implementation
An implementation of window.fetch in Node.js using Minipass streams
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.
Merge multiple streams into a unified stream
The string_decoder module from Node core
A small fast zlib stream built on [minipass](http://npm.im/minipass) and Node.js's zlib binding.
Turn a readable stream into multiple readable streamx streams
Chain functions, generators, Node streams, and Web streams into a pipeline with backpressure support.
Allows libraries to handle various caller provided asynchronous functions uniformly. Maps promises, observables, child processes and streams, and callbacks to callback style.
Settle an async function.
JSON.Stringify as a readable stream
Open Node Streams on demand.
Convert JSON to CSV
Streams for reading/writing messages
An async iterator that joins multiple other async iterators in order, one after another.
A Promise-based interface into processes created by child_process.spawn
A library that makes it easier to work with Streams in the browser.
Asynchronous streams using async & await notation
Lightweight stream generator library
Simple crate that wraps a tokio::process into a tokio::stream
Lightweight implementation of `async-stream` without macros
Thin wrapper around [`tokio::process`] to make it streamable
High-performance async network encryption library featuring XChaCha20-Poly1305, type-safe protocol DSL, and zero-copy packet streaming for secure communication channels
proc macros for async-stream crate
Implement an async iterator with return value.
Implement an async iterator with return value.
Implement a coroutine like C#'s `yield return` using Rust's `async`, `await`.
A gRPC service for monitoring system resources such as CPU, memory, and disk.
High-performance data profiler with ISO 8000/25012 quality metrics for CSV, JSON/JSONL, and Parquet files
VSM is a small Ruby framework for building agentic systems using a Viable System Model–style architecture. It gives you Capsules: self‑contained components composed of five named systems (Operations, Coordination, Intelligence, Governance, Identity) plus an async runtime so many capsules can run concurrently.
The AssemblyAI Ruby SDK provides an easy-to-use interface for interacting with the AssemblyAI API, which supports async, audio intelligence models, as well as the latest LeMUR models. The Ruby SDK does not support Streaming STT at this time.
Stream State Protocol events from Active Record models with the same DX as Turbo Broadcasts — declarative streaming, automatic callbacks, and async jobs — but with offset-based resumability and persistent event logs over HTTP.
Pure Ruby implementation of nanomsg's Scalability Protocols (SP) on top of async + io-stream. Per-socket HWM, opportunistic batching, wire-compatible with libnng over inproc/ipc/tcp.
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.
Pure Ruby implementation of MQTT — client and broker in one gem — built on async, io-stream, and protocol-mqtt. Fiber-first, pluggable transports (tcp, tls, ws, ipc), pluggable persistence (in-memory, PStore).
llm.rb is Ruby's most capable AI runtime. It runs on Ruby's standard library by default. loads optional pieces only when needed, and offers a single runtime for providers, agents, tools, skills, MCP, A2A (Agent2Agent), RAG (vector stores & embeddings), streaming, files, and persisted state. As a bonus, llm.rb is also available for mruby. It supports OpenAI, OpenAI-compatible endpoints, Anthropic, Google Gemini, DeepSeek, xAI, Z.ai, AWS Bedrock, Ollama, and llama.cpp. It also includes built-in ActiveRecord and Sequel support, plus concurrent tool execution through threads, tasks (via async gem), fibers, ractors, and fork (via xchan.rb gem).
Ruby SDK for ARCP: envelope and message model, fiber-based runtime, client, WebSocket / stdio / in-memory transports, SQLite-backed resume log, capability negotiation, leases with budget and expiration, streamed results, and OpenTelemetry trace propagation. Built on socketry/async.
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.