A stream that emits multiple other streams one after another (streams2)
Simple, robust streams2 version of combined-stream. Allows you to combine multiple streams into a single stream. When the first stream ends, the next one starts, and so on, until all streams are consumed.
This module is used by WebTorrent, specifically create-torrent.
install
npm install multistream
usage
Use multistream
like this:
var MultiStream = require('multistream')
var fs = require('fs')
var streams = [
fs.createReadStream(__dirname + '/numbers/1.txt'),
fs.createReadStream(__dirname + '/numbers/2.txt'),
fs.createReadStream(__dirname + '/numbers/3.txt')
]
MultiStream(streams).pipe(process.stdout) // => 123
To lazily create the streams, wrap them in a function:
var streams = [
fs.createReadStream(__dirname + '/numbers/1.txt'),
function () { // will be executed when the stream is active
return fs.createReadStream(__dirname + '/numbers/2.txt')
},
function () { // same
return fs.createReadStream(__dirname + '/numbers/3.txt')
}
]
MultiStream(streams).pipe(process.stdout) // => 123
Alternativelly, streams may be created by a generator function:
var count = 0;
var streams = function () {
if (count > 3) return false
count++
return fs.createReadStream(__dirname + '/numbers/' + count + '.txt')
}
MultiStream(streams).pipe(process.stdout) // => 123
contributors
license
MIT. Copyright (c) Feross Aboukhadijeh.