streamss-cat

Concatenate stream2 streams to one stream

Concatenate streams to behave like one Readable Stream. This is a pure Stream2 implementation which respects also a very high number of input streams (>1000).

Works with node v0.8.x and greater. For node v0.8.x the user-land copy readable-stream is used. For all other node versions greater v0.8.x the built-in stream module is used.

Credits go to stream-cat.

Examples

Join two streams:

let Through = require('streamss').Through;
let cat = require('streamss-cat');

let stream1 = new Through();
let stream2 = new Through();

cat(stream1, stream2).pipe(process.stdout);
//cat([stream1, stream2]).pipe(process.stdout); //< alternatively

stream1.end('hello ');
stream2.end('world');

Join thousand fs streams with allocating the resources on runtime:

let fs = require('fs');
let cat = require('../');
let streams = [];

function fnStream() {
	return fs.createReadStream(__filename);
}

for (let i=0; i<1000; i++) {
	streams.push(fnStream);
}

cat(streams).pipe(process.stdout);

Methods

cat(streams)

Concatenate Streams to a readable stream

Parameters:

• {Readable} streams - Array of Readable Streams or Array of Functions returning Readable Streams

Return:

{Readable} A readable stream

Contribution and License Agreement

If you contribute code to this project, you are implicitly allowing your code to be distributed under the MIT license. You are also implicitly verifying that all code is your original work or correctly attributed with the source of its origin and licence.

npm scripts

• npm test - Run tests
• npm run cover - Run istanbul code coverage (shows code coverage; open ./coverage/lcov-report/index.html after run)
• npm run lint - Linting the source
• npm run doc - Generate documentation from source (open ./doc/index.html after run)

License

Copyright (c) 2015 commenthol (MIT License)

See LICENSE for more info.