Streams2 Packages

A transform stream that collects chunks and passes them on as batches

A stream that transforms chunks to batches form the stream

New-line separated JSON streaming

An abstraction for making stream.Writable streams without all the boilerplate.

redis-rstream - node.js redis read stream which streams binary or utf8 data in chunks from a redis key using an existing redis client (streams2)

redis-wstream - node.js redis write stream which streams binary or utf8 data into a redis key using an existing redis client (streams2)

Streamable content addressable blob object store that is streams2 and implements the blob store interface on top of the fs module

Collect all data piped to this stream when it closes

Transforms and other streaming helpers

A Node Streams2 CSV parser

Streams2 line reader

Through stream that parses each write as a JSON message.

accum - Simple write stream which accumulates or collects the data from a stream. Pipe your stream into this to get all the data as buffer, string, or raw array. (streams2)

Streams2 implementation that inputs plain strings, bunyan records, glossy records, and outputs syslog formatted strings

a through stream that destroys itself if an overall size limit for the combined stream throughput is exceeded

Multi-transport Syslog stream with reconnect

Transform stream that truncates

Read from a stream using Promises.

A tiny wrapper around Node.js streams.Transform (Streams2/3) to avoid explicit subclassing noise

simple promise-based streams