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.

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

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

Fork stream based on passed condition, and collect down-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.

Spawn a child process as a duplex stream

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

RxJS Bindings for Node.js and io.js

Pipe an Array through Node.js streams

stream balance

Iterate all the data in a stream

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

Create streams from promises

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

Generic interruptible "parser" mixin for Transform & Writable streams

Deserialize JSON from a stream

Convert streams (readable or writable) to promises

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

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

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

A through2 wrapper to for simple stream.PassThrough spies.

Scans a DynamoDB table and puts the items into SQS for processing