ghaction-upx/node_modules/get-stream/buffer-stream.js

52 lines
841 B
JavaScript
Raw Normal View History

2020-01-17 01:36:42 -07:00
'use strict';
2020-04-03 02:12:31 -06:00
const {PassThrough} = require('stream');
2020-01-17 01:36:42 -07:00
2020-04-03 02:12:31 -06:00
module.exports = options => {
options = Object.assign({}, options);
2020-01-17 01:36:42 -07:00
2020-04-03 02:12:31 -06:00
const {array} = options;
let {encoding} = options;
2020-01-17 01:36:42 -07:00
const buffer = encoding === 'buffer';
let objectMode = false;
if (array) {
objectMode = !(encoding || buffer);
} else {
encoding = encoding || 'utf8';
}
if (buffer) {
encoding = null;
}
let len = 0;
const ret = [];
const stream = new PassThrough({objectMode});
if (encoding) {
stream.setEncoding(encoding);
}
stream.on('data', chunk => {
ret.push(chunk);
if (objectMode) {
len = ret.length;
} else {
len += chunk.length;
}
});
stream.getBufferedValue = () => {
if (array) {
return ret;
}
return buffer ? Buffer.concat(ret, len) : ret.join('');
};
stream.getBufferedLength = () => len;
return stream;
};