TypeScript definitions for async-stream-emitter
Give streams support for asyncronous processing.
TypeScript definitions for async-stream-generator
A readable async stream which can be iterated over using a for-await-of loop.
An async stream which can be iterated over using a for-await-of loop.
An alternantive to EventEmitter using consumable streams.
Single-consumer push-pull async stream with enqueue/done/error semantics (inspired by claude-code Stream<T>)
Robust async, stream-first Git plumbing for Node, Bun, and Deno.
A readable async stream which can be iterated over using a for-await-of loop.
Pipe ES6 Async Generators through Node.js Streams
Stream that calls an async function with each chunk.
An async stream which can be iterated over using a for-await-of loop.
Async stream pipeline
Get a stream as a string, Buffer, ArrayBuffer or array
An async stream which can be iterated over using a for-await-of loop.
node.js library for reading and extraction of ZIP archives
A readable async stream which can be iterated over using a for-await-of loop.
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
a streaming zip archive generator.
Clone a Node.js HTTP response stream
Encode FormData content into the multipart/form-data format
JSON.Stringify as a readable stream
Chain functions, generators, Node streams, and Web streams into a pipeline with backpressure support.
Streaming utilities for AI assistants
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.