diff options
Diffstat (limited to 'deps/node/deps/npm/node_modules/got/node_modules/get-stream/buffer-stream.js')
-rw-r--r-- | deps/node/deps/npm/node_modules/got/node_modules/get-stream/buffer-stream.js | 51 |
1 files changed, 0 insertions, 51 deletions
diff --git a/deps/node/deps/npm/node_modules/got/node_modules/get-stream/buffer-stream.js b/deps/node/deps/npm/node_modules/got/node_modules/get-stream/buffer-stream.js deleted file mode 100644 index ae45d3d9..00000000 --- a/deps/node/deps/npm/node_modules/got/node_modules/get-stream/buffer-stream.js +++ /dev/null @@ -1,51 +0,0 @@ -'use strict'; -const PassThrough = require('stream').PassThrough; - -module.exports = opts => { - opts = Object.assign({}, opts); - - const array = opts.array; - let encoding = opts.encoding; - 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; -}; |