stream-que
v1.0.2
Published
converting array of strings and streams into a single stream
Downloads
23
Readme
stream-que
converting JavaScript Array of strings and streams into a sequential flow of data in a single stream.
Like a one-lane highway for stream.
Install
npm install --save stream-que
Usage
var Streamque = require('stream-que');
var highway = Streamque([
'Hello ',
fs.createReadStream('./file/world')
]);
highway.stream().pipe(process.stdout);
/*
* Assuming the file "./file/world" contains "world."
* The outcome in your console would be "Hello world."
*/
Count string size
This will only work if all the streams are created using fs.createReadStream
var highway = Streamque([
'Hello ',
fs.createReadStream( './file/world' )
]);
highway.count().then((total) => {
console.log( 'Total size: ' + total )
highway.stream().pipe( process.stdout )
});
/*
* Total size: 12
* Hello world.
*/
Manual start
Flowing mode will start on .pipe()
, and listening on events such as data
and readable
. But, if you really have to make it start by yourself:
highway.start();
// and it flows.
fyi: This is written es6. and tested on node.js 4.4.0