construct pipes of streams of events
TypeScript definitions for map-stream
Like map-stream but with concurrency limit
A version of map-stream with support for callbacks, promises, observables and streams.
map-stream with n-way concurrency
An iteration of the Node.js core streams with a series of improvements
Security Trust Report: map-stream@0.0.7 — 70/100 (B, standard). Maintainer risk, supply chain analysis from 8 security databases.
Streaming mapping of tarball headers
transform through/map stream
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.
Vinyl adapter for the file system.
Convert Node Streams into ECMAScript-Observables
Node.js Streams, a user-land copy of the stream library from Node.js
A streaming data transport format that aims to support built-in features such as Promises, Dates, RegExps, Maps, Sets and more.
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.
Toggle the CLI cursor
destroy a stream if possible
Call a callback when a readable/writable/duplex stream has completed or failed.
Generates and consumes source maps
Generates and consumes source maps
Simple in-memory vinyl file store
Get and validate the raw body of a readable stream.
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).
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.
No description provided.
No description provided.