Concurrent transform stream
Transform stream that allows async function to be called in parallel while still consuming results into a syncronous stream'
Transform stream that allows you to run your transforms in parallel without changing the order
Run an array of functions in parallel
Object transformations implementing the Node.js `stream.Transform` API
Minimal async jobs utility library, with streams support
safely create multiple ReadStream or WriteStream objects from the same file descriptor
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
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.
Toggle the CLI cursor
destroy a stream if possible
A tiny, zero-dependency yet spec-compliant asynchronous iterator polyfill/ponyfill for ReadableStreams.
Run an array of functions in parallel, but limit the number of tasks executing at the same time
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.
Get and validate the raw body of a readable stream.
Creates a parallel transform from async function
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
Merge multiple streams into a unified stream
An iteration of the Node.js core streams with a series of improvements
Data parallelism library for async-std
Output a tally of the number of times unique words appear in source input.
Easily specify which scripts to run, which ones to run in parallel, control their exit status and stream their output to a websockt.
SmarterCSV is a high-performance CSV reader and writer for Ruby focused on fastest end-to-end ingestion — not just parsing. It returns ready-to-use hashes with configurable header and value transformations, intelligent defaults, and automatic delimiter discovery. Built for real-world data pipelines, SmarterCSV supports chunked processing for large files, streaming via Enumerable APIs, and C acceleration to optimize the full ingestion path (parsing + hash construction + conversions). Designed to handle messy user-uploaded CSV while remaining easy to integrate with Rails, ActiveRecord imports, Sidekiq jobs, parallel processing, and S3-based workflows.
JRubyParallelProcessing is a gem for parallel processing tasks in JRuby. It provides classes for efficient data processing, task management with priority and retries, and parallel API request handling. It includes features such as middleware support, stream processing, and distributed task execution.
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.