| Server IP : 49.231.201.246 / Your IP : 216.73.216.146 Web Server : Apache/2.4.18 (Ubuntu) System : Linux 246 4.4.0-210-generic #242-Ubuntu SMP Fri Apr 16 09:57:56 UTC 2021 x86_64 User : root ( 0) PHP Version : 7.0.33-0ubuntu0.16.04.16 Disable Function : exec,passthru,shell_exec,system,proc_open,popen,pcntl_exec MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /proc/thread-self/root/var/www/html/ppaobm/vendor/bower-asset/sweetalert2/utils/ |
Upload File : |
const { Duplex } = require('stream')
module.exports.map = function (mapfn) {
const stream = new Duplex({
write (chunk, encoding, callback) {
this.push(mapfn(chunk))
callback()
},
read () {}
})
return stream
}
module.exports.split = function () {
const stream = new Duplex({
write (chunk, encoding, callback) {
this.buffer = (this.buffer || '') + chunk.toString()
if (/\r?\n/.test(chunk.toString())) {
let splitChunks = this.buffer.split(/\r?\n/)
for (let i = 0; i < splitChunks.length - 1; i++) {
this.push(splitChunks[i])
}
this.buffer = splitChunks[splitChunks.length -1]
}
callback()
},
read () {}
})
return stream
}
module.exports.merge = function (/* streams... */) {
let toMerge = [].slice.call(arguments)
const stream = new Duplex({
write (chunk, encoding, callback) {
this.push(chunk)
callback()
},
read() {}
})
if (toMerge.length) {
toMerge.forEach(function (e) {
e.pipe(stream, { end: false })
})
}
return stream
}