diff options
| author | littleblack111 <littleblack11111@gmail.com> | 2026-05-18 23:10:59 +0800 |
|---|---|---|
| committer | littleblack111 <littleblack11111@gmail.com> | 2026-05-18 23:41:44 +0800 |
| commit | fc87c009806dcc98867f6b58efe29b042aa01dee (patch) | |
| tree | 8f59b3f4a5b66e9dfef2d40c8d318e258a521228 /node_modules/gather-stream/index.js | |
| parent | 3336b2356ee6152d9c6ae59bd9b87ccbc0958407 (diff) | |
node: updatemain
Diffstat (limited to 'node_modules/gather-stream/index.js')
| -rw-r--r-- | node_modules/gather-stream/index.js | 44 |
1 files changed, 0 insertions, 44 deletions
diff --git a/node_modules/gather-stream/index.js b/node_modules/gather-stream/index.js deleted file mode 100644 index cab8bda9..00000000 --- a/node_modules/gather-stream/index.js +++ /dev/null @@ -1,44 +0,0 @@ -var Writable = require('stream').Writable, - util = require('util'); - -function Gatherer(opts) { - opts.decodeStrings = true; - Writable.call(this, opts); - this._length = 0; - this._chunks = []; - this._maxLength = ('maxLength' in opts) ? opts.maxLength : Infinity; -} - -util.inherits(Gatherer, Writable); - -Gatherer.prototype._write = function (d, _enc, cb) { - if (this._length + d.length > this._maxLength) { - return cb(new Error("Maximum length exceeded!")); - } - this._chunks.push(d); - this._length += d.length; - cb(); -} - -Gatherer.prototype.getBuffer = function () { - return Buffer.concat(this._chunks, this._length); -} - -module.exports = function (opts, cb) { - if (typeof opts === 'function') { - cb = opts; - opts = {}; - } - var target = new Gatherer(opts); - target.on('error', cb); - target.on('pipe', function (source) { - source.on('error', cb); - }); - target.on('unpipe', function (source) { - source.removeListener('error', cb); - }); - target.on('finish', function () { - cb(null, target.getBuffer()); - }); - return target; -} |
