Make a full duplex stream with 2 Duplex endpoints, using the native version of `Duplex`
Specialized async queue data structure
A through2 to create an Array.prototype.filter analog for streams.
Web Streams, based on the WHATWG spec reference implementation
Better observables for everyone
A rate limiter for Node.js streams.
A stream meter that both counts the bytes piped through it, and can optionally abort on a max size. (e.g. limit a http request size)
Buffer and transform the n first bytes of a stream
Fast & forgiving HTML/XML/RSS parser
Fast, simple data pipelines
A functional stream library implementation runs on browsers and node.js
Reflects Kefir streams so they work with the rest of CanJS
Rename assets with fingerprinted assets
Create tarball from files
Streams groups of chunks based on conditions or an interval
A binary transform stream splitting chunks by newline characters
A sockethub platform module implementing XMPP functionality
JSON schema files for validating Sockethub Activity Streams
A NodeJS package to read XML files using NodeJS streams.