/
var
/
www
/
cobraambalaj
/
node_modules
/
merge-stream
/
/var/www/cobraambalaj/node_modules/merge-stream
mkdir
upload
Name
Size
Mode
Actions
index.js
885
0644
edit
dl
rm
LICENSE
1119
0644
edit
dl
rm
package.json
1526
0644
edit
dl
rm
README.md
1813
0644
edit
dl
rm
Edit:
/var/www/cobraambalaj/node_modules/merge-stream/index.js
(885B)
'use strict'; const { PassThrough } = require('stream'); module.exports = function (/*streams...*/) { var sources = [] var output = new PassThrough({objectMode: true}) output.setMaxListeners(0) output.add = add output.isEmpty = isEmpty output.on('unpipe', remove) Array.prototype.slice.call(arguments).forEach(add) return output function add (source) { if (Array.isArray(source)) { source.forEach(add) return this } sources.push(source); source.once('end', remove.bind(null, source)) source.once('error', output.emit.bind(output, 'error')) source.pipe(output, {end: false}) return this } function isEmpty () { return sources.length == 0; } function remove (source) { sources = sources.filter(function (it) { return it !== source }) if (!sources.length && output.readable) { output.end() } } }
Save
cmd:
run