awesome-nodejs-streams

Awesome resources and modules for Streams in Node

Articles

• Why I don't use Node's core 'stream' module
• stream-handbook
• The Definitive Guide to Object Streams in Node.js

Interactive

• stream-adventure

Talks

• James Halliday - Harnessing The Awesome Power Of Streams

Modules

• lewisdiamond/stromjs - Dependency-free stream utils. The Lodash of streams.
• almost/through2-concurrent - Simple Node.JS stream (streams2) Transform that runs the transform functions concurrently (with a set max concurrency)
• bendrucker/stream-to-promise - Convert streams (readable or writable) to promises
• grncdr/merge-stream - Merge multiple streams into one interleaved stream
• dominictarr/event-stream - EventStream is like functional programming meets IO
• dominictarr/map-stream - refactored out of event-stream
• dominictarr/JSONStream - streaming JSON.parse and stringify
• dominictarr/split - Break up a stream and reassemble it so that each line is a chunk. matcher may be a String, or a RegExp
• dominictarr/stream-combiner - Turn a pipeline into a single stream. Combine returns a stream that writes to the first stream and reads from the last stream
• dominictarr/stream-spec - executable specification for Stream (make testing streams easy)
• feross/multistream - A stream that emits multiple other streams one after another (streams2)
• floatdrop/stream-assert - Assertion library for streams
• freeall/progress-stream - Read the progress of a stream
• gagle/node-streamifier - Converts a Buffer/String to a readable stream.
• hughsk/from2 - Convenience wrapper for ReadableStream, inspired by through2
• jahewson/node-byline - Line-by-line Stream reader
• kikobeats/stream-callback – Turns a stream into a callback.
• mafintosh/duplexify - Turn a writeable and readable stream into a streams2 duplex stream with support for async initialization and streams1/streams2 input
• mafintosh/end-of-stream - Call a callback when a readable/writable/duplex stream has completed or failed
• mafintosh/flush-write-stream - A write stream constructor that supports a flush function that is called before finish is emitted
• mafintosh/peek-stream - Transform stream that lets you peek the first line before deciding how to parse it
• mafintosh/pump - pipe streams together and close all of them if one of them closes
• mafintosh/pumpify - Combine an array of streams into a single duplex stream using pump and duplexify
• mafintosh/multi-read-stream - Readable stream that reads from multiple readable streams at the same time
• mafintosh/multi-write-stream - Create a writable stream that writes to multiple other writeable streams
• mafintosh/stream-each - Iterate all the data in a stream
• mafintosh/stream-shift - Returns the next buffer/object in a stream's readable queue
• mafintosh/tar-stream - tar-stream is a streaming tar parser and generator
• maxogden/binary-split - A fast newline (or any delimiter) splitter stream
• maxogden/concat-stream - writable stream that concatenates strings or data and calls a callback with the result
• maxogden/mississippi - A collection of useful stream utility modules for writing better code using streams
• maxogden/ndjson - streaming line delimited json parser + serializer](https://github.com/mcollina/cloneable-readable)
• mcollina/cloneable-readable - Clone a Readable stream, safely
• mcollina/split2 - Split streams3 style
• nodejs/readable-stream - Node-core streams for userland
• npm/fstream - Advanced FS Streaming for Node
• parshap/node-stream-reduce - Reduce stream data to a single value
• raynos/duplexer - Creates a duplex stream
• rvagg/isstream - Determine if an object is a Node.js Stream
• rvagg/through2 - Tiny wrapper around Node streams2 Transform to avoid explicit subclassing noise
• samcday/node-stream-buffer - Readable and Writable Streams that use backing Buffers
• schnittstabil/stream-from-promise - Create streams from promises
• sindresorhus/first-chunk-stream - Buffer and transform the n first bytes of a stream
• sindresorhus/get-stream - Get a stream as a string, buffer, or array
• sindresorhus/into-stream - Convert a buffer/string/array/object into a stream
• sindresorhus/is-stream - Check if something is a Node.js stream
• spion/promise-streams - A collection of node.js streams that work well with promises (through, map, reduce, etc...)
• stream-utils/destroy - destroy a stream if possible
• suarasaur/exec-stream - stream to a child process
• substack/emit-stream - turn event emitters into streams and streams into event emitters
• substack/oppressor - streaming http compression response negotiator
• substack/stream-combiner2 - stream-combiner for streams3
• substack/resumer - a through stream that starts paused and resumes on the next tick
• teambition/merge2 - Merge multiple streams into one stream in sequence or parallel
• uhop/stream-json - stream-json is a collection of node.js stream components for creating custom standard-compliant JSON processors, which requires a minimal memory footprint. It can parse JSON files far exceeding available memory. Even individual primitive data items (keys, strings, and numbers) can be streamed piece-wise. Streaming SAX-inspired event-based API is included as well.
• caolan/highland - The high-level streams library for Node.js and the browser.