2 Object.defineProperty(exports, "__esModule", { value: true });
\r
3 var merge2 = require("merge2");
\r
5 * Merge multiple streams and propagate their errors into one stream in parallel.
\r
7 function merge(streams) {
\r
8 var mergedStream = merge2(streams);
\r
9 streams.forEach(function (stream) {
\r
10 stream.on('error', function (err) { return mergedStream.emit('error', err); });
\r
12 return mergedStream;
\r
14 exports.merge = merge;
\r