summaryrefslogtreecommitdiff
path: root/deps/npm/node_modules/libnpx/node_modules/yargs/node_modules/os-locale/node_modules/execa/node_modules/get-stream/buffer-stream.js
diff options
context:
space:
mode:
Diffstat (limited to 'deps/npm/node_modules/libnpx/node_modules/yargs/node_modules/os-locale/node_modules/execa/node_modules/get-stream/buffer-stream.js')
-rw-r--r--deps/npm/node_modules/libnpx/node_modules/yargs/node_modules/os-locale/node_modules/execa/node_modules/get-stream/buffer-stream.js33
1 files changed, 15 insertions, 18 deletions
diff --git a/deps/npm/node_modules/libnpx/node_modules/yargs/node_modules/os-locale/node_modules/execa/node_modules/get-stream/buffer-stream.js b/deps/npm/node_modules/libnpx/node_modules/yargs/node_modules/os-locale/node_modules/execa/node_modules/get-stream/buffer-stream.js
index cc834c4dc8..ae45d3d9e7 100644
--- a/deps/npm/node_modules/libnpx/node_modules/yargs/node_modules/os-locale/node_modules/execa/node_modules/get-stream/buffer-stream.js
+++ b/deps/npm/node_modules/libnpx/node_modules/yargs/node_modules/os-locale/node_modules/execa/node_modules/get-stream/buffer-stream.js
@@ -1,14 +1,13 @@
-var PassThrough = require('stream').PassThrough;
-var objectAssign = require('object-assign');
+'use strict';
+const PassThrough = require('stream').PassThrough;
-module.exports = function (opts) {
- opts = objectAssign({}, opts);
+module.exports = opts => {
+ opts = Object.assign({}, opts);
- var array = opts.array;
- var encoding = opts.encoding;
-
- var buffer = encoding === 'buffer';
- var objectMode = false;
+ const array = opts.array;
+ let encoding = opts.encoding;
+ const buffer = encoding === 'buffer';
+ let objectMode = false;
if (array) {
objectMode = !(encoding || buffer);
@@ -20,16 +19,15 @@ module.exports = function (opts) {
encoding = null;
}
- var len = 0;
- var ret = [];
-
- var stream = new PassThrough({objectMode: objectMode});
+ let len = 0;
+ const ret = [];
+ const stream = new PassThrough({objectMode});
if (encoding) {
stream.setEncoding(encoding);
}
- stream.on('data', function (chunk) {
+ stream.on('data', chunk => {
ret.push(chunk);
if (objectMode) {
@@ -39,16 +37,15 @@ module.exports = function (opts) {
}
});
- stream.getBufferedValue = function () {
+ stream.getBufferedValue = () => {
if (array) {
return ret;
}
+
return buffer ? Buffer.concat(ret, len) : ret.join('');
};
- stream.getBufferedLength = function () {
- return len;
- };
+ stream.getBufferedLength = () => len;
return stream;
};