Nodejs merging object streams. Here is my current working example. But I dont like it. A MergeStream with one 'end' event would be much better. A sidenode: FeedParser implements node TransformStream and set its objectmode to true so that in the end we stream objects instead buffers. This could be better solved with RxJS. But what I currently don…

object_stream_merging.js

var data = [];
exampleFeeds.forEach(function(feedFile) {
    fs.createReadStream(feedFile)
        .pipe(new FeedParser())
        .on('meta', function(meta) {
            data.push(meta);
            if(data.length===exampleFeeds.length){
                console.log('done '+data.length);
                // do something
            }
        });
});

I think plenty of people have written merging streams, this one looks right https://npmjs.org/package/merge-stream

@dominictarr Thanks for pointing this out, looks great :-)

+1

Thx that works like I expect. I dont know why I dont got this. Ive tried this one https://github.com/felixge/node-combined-stream which dose not work like I am expecting.