htoooth/mississippi2

writable stream that concatenates strings or binary data and calls a callback with the result

Turn a writable and readable stream into a streams2 duplex stream with support for async initialization and streams1/streams2 input

Call a callback when a readable/writable/duplex stream has completed or failed.

pipe streams together and close all of them if one of them closes

Combine an array of streams into a single duplex stream using pump and duplexify

split a Text Stream into a Line Stream, using Stream 3

Iterate all the data in a stream

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

A through2 to create an Array.prototype.filter analog for streams.

A through2 to create an Array.prototype.map analog for streams.

A through2 wrapper to for simple stream.PassThrough spies.

Spawn a child process as a duplex stream

A write stream constructor that supports a flush function that is called before finish is emitted

Convenience wrapper for ReadableStream, with an API lifted from "from" and "through2"

RxJS Bindings for Node.js and io.js

Pipe an Array through Node.js streams

Create streams from arrays of arbitrary Javascript values like strings, functions, arrays, etc.

Create streams from promises

Generic interruptible "parser" mixin for Transform & Writable streams

Deserialize JSON from a stream

stream balance

Pipe a stream into a string, collect value with callback or promise

Fork stream based on passed condition, and collect down-stream

Node.js Transform stream that passes data through at `n` bytes per second

A through2 wrapper to emulate Array.prototype.reduce for streams.

Convert streams (readable or writable) to promises

Create streams from (single) arbitrary Javascript values like strings, functions, arrays, etc.