concatstream.js

'use strict';

var Transform = require('stream').Transform,
    inherits = require('util').inherits,
    fs = require('fs');

function ConcatStream() {
    Transform.call(this, {
        writableObjectMode: true
    });
}
inherits(ConcatStream, Transform);
ConcatStream.prototype._transform = function (obj, ignore, callback) {
    var stream = fs.createReadStream(obj.path),
        self = this;
    
    stream.on('data', function (chunk) {
        self.push(chunk);
    });
    stream.on('error', function (err) {
        callback(err);
    });
    stream.on('end', function () {
        callback();
    });
};


var test = new ConcatStream();
test.write({ path: __filename })
test.write({ path: __filename })
test.on('data', function (chunk) {
    console.log(chunk.toString());
});
test.end();