Sha256: 6190bc687b3b2c35d53077ef4762dd47369a871057282620785abe7ecd0724bd
Contents?: true
Size: 621 Bytes
Versions: 23
Compression:
Stored size: 621 Bytes
Contents
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const merge2 = require("merge2");
function merge(streams) {
const mergedStream = merge2(streams);
streams.forEach((stream) => {
stream.once('error', (error) => mergedStream.emit('error', error));
});
mergedStream.once('close', () => propagateCloseEventToSources(streams));
mergedStream.once('end', () => propagateCloseEventToSources(streams));
return mergedStream;
}
exports.merge = merge;
function propagateCloseEventToSources(streams) {
streams.forEach((stream) => stream.emit('close'));
}
Version data entries
23 entries across 23 versions & 1 rubygems