<div align="center"> <h1>schema-stream</h1> </div> <br />
Node.js Streams, a user-land copy of the stream library from Node.js
Parse binary files with a schema into nicely readable objects
Check if something is a Node.js stream
> [!WARNING] > The agents and hooks packages are no longer maintained and schema-stream has moved here: [island-ai](https://github.com/hack-dance/island-ai) > Agents has been mostly replaced by zod-stream and the hooks package has moved to stream-hooks -
Get a stream as a string, Buffer, ArrayBuffer or array
The missing standard library for TypeScript, for writing production-grade software.
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.
Toggle the CLI cursor
destroy a stream if possible
Call a callback when a readable/writable/duplex stream has completed or failed.
Traverse JSON Schema passing each schema object to callback
Get and validate the raw body of a readable stream.
Functional programming in TypeScript
A streaming way to send data to a Node.js Worker Thread
A stream that emits multiple other streams one after another.
Streaming data for JavaScript
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
Merge multiple streams into a unified stream
An iteration of the Node.js core streams with a series of improvements
Returns the next buffer/object in a stream's readable queue
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.
Streaming HTML parser with scripting support.
The string_decoder module from Node core
Message schemas for data-oriented command streams used to populate view databases
acts_as_activitable is a gem that creates a database schema, methods and relationships for creating Facebook-like activity stream functionality
Persistent event repository implementation for RubyEventStore based on ActiveRecord. Ships with database schema and migrations suitable for PostgreSQL, MySQL ans SQLite database engines. Includes repository implementation with linearized writes to achieve log-like properties of streams on top of SQL database engine.
Persistent event repository implementation for RubyEventStore based on ActiveRecord. Ships with database schema and migrations suitable for PostgreSQL, MySQL ans SQLite database engines. Includes repository implementation with linearized writes to achieve log-like properties of streams on top of SQL database engine.
Embed an AI-powered database chatbot into any Rails application. Auto-discovers your PostgreSQL schema, indexes your codebase, generates SQL from natural language, and streams answers through a chat widget. Zero configuration required.
A full-featured TOON encoder/decoder with JSON feature parity: streaming, hooks, pretty generate, strict parsing, schema hints, CLI and ActiveSupport integration.
SolidAgent extends ActiveAgent with database-backed prompt context management, declarative tool schemas, and real-time streaming updates. Provides has_context, has_tools, and streams_tool_updates concerns for building robust AI agents.
A failure-aware, contract-driven Ruby client for the Ollama API. Provides deterministic /generate with strict JSON schema validation, automatic model pulling, exponential backoff on timeouts, and observer-style streaming hooks. Designed for Rails background jobs and agent planners — not a chatbot UI.
Idiomatic Ruby client for Groq's OpenAI-compatible API. Covers chat completions (sync + streaming), embeddings, audio (speech, transcription, translation), models, files, and batches. Built on Net::HTTP, with parameter validation via dry-schema and internal Result-based control flow via dry-monads.
This gem is an adapter for the dogstatsd-ruby gem. Unlike the Datadog::Statsd metric sender, this gem supports pre-declaring schemas defining allowed metrics and their types, the tags that apply to them, and tag values that must be validated before streamed to Datadog. This approach allows for a more robust and consistent way to ensure that metrics follow a well-thought-out naming scheme and are validated before being sent to Datadog.
Scrapetor is a Ruby HTML parsing + scraping toolkit. The parser is a native C arena DOM with structural indexes built at parse time and NEON SIMD scanners in the SAX hot loop. A streaming extraction engine compiles the schema DSL into a single forward pass — no DOM materialised, one Ruby boundary crossing per document. On builds where libcurl is available, Scrapetor::Fetcher adds an HTTP/2-capable fetch layer with per-thread connection cache, shared DNS + TLS session pool, in-process gzip / deflate / brotli / zstd decoding, iconv charset transcoding, retry + exponential backoff, ETag / Last-Modified disk cache with bulk revalidation, per-host throttle, cookie jar, basic + bearer auth, proxy, and three bulk concurrency models (parallel_fetch / multi_fetch / streaming multi_each). Scrapetor::Session ties the cookie / auth / throttle / retry policies together. Also ships robots.txt + sitemap.xml parsers, a bounded-memory streaming HTML parser, and structured-data extractors (JSON-LD, OpenGraph, Schema.org, Microdata, RDFa, Twitter Cards). The Net::HTTP-based Scrapetor.fetch is preserved as the no-libcurl fallback.
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.