Augments Stream's prototype with map, filter and reduce
A map function for Web Streams with concurrency support. Like node's ReadableStream.map(), but for Web Streams.
An iteration of the Node.js core streams with a series of improvements
construct pipes of streams of events
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.
Node.js Streams, a user-land copy of the stream library from Node.js
Vinyl adapter for the file system.
A streaming data transport format that aims to support built-in features such as Promises, Dates, RegExps, Maps, Sets and more.
Convert Node Streams into ECMAScript-Observables
Check if something is a Node.js stream
Get a stream as a string, Buffer, ArrayBuffer or array
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
Toggle the CLI cursor
Get and validate the raw body of a readable stream.
Generates and consumes source maps
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
Generates and consumes source maps
Simple in-memory vinyl file store
Streaming data for JavaScript
Gulp plugin for generating an identity sourcemap for a file.
Fixes stack traces for files with source maps
A streaming way to send data to a Node.js Worker Thread
Build CSV files from record collections using a declarative DSL with column definitions, custom transforms, filtering, sorting, pagination via limit/offset, computed footer rows, row numbers, streaming output, custom delimiters and line separators, TSV/PSV shorthands, row validation, header transforms, total rows, append-to-file support, and custom empty-value placeholders.
Classes to process various joins in Hadoop Map/Reduce Streaming.
Rubydoop embeds a JRuby runtime in Hadoop, letting you write map reduce code in Ruby without using the streaming APIs
Uses AMQP stream queues (RabbitMQ 3.9+ / LavinMQ) as a key-value store. Each key maps to a dedicated stream queue; the latest message is the current value.
Auto-syncs records in client-side JS (through a Model DSL) from changes (updates/destroy) in the backend Rails server through ActionCable. Also supports streaming newly created records to client-side JS. Supports lost connection restreaming for both new records (create), and record-changes (updates/destroy). Auto-updates DOM elements mapped to a record attribute, from changes (updates/destroy).
A lightweight, dependency-free Ruby client for the Tavily API. The web access layer built for LLMs and AI agents. Wraps the search, extract, crawl, map, and research endpoints with typed response objects, automatic retries with backoff, streaming research, and granular error handling.
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.