summaryrefslogtreecommitdiff
path: root/node_modules/gather-stream/index.js
diff options
context:
space:
mode:
authorlittleblack111 <littleblack11111@gmail.com>2026-05-18 23:10:59 +0800
committerlittleblack111 <littleblack11111@gmail.com>2026-05-18 23:41:44 +0800
commitfc87c009806dcc98867f6b58efe29b042aa01dee (patch)
tree8f59b3f4a5b66e9dfef2d40c8d318e258a521228 /node_modules/gather-stream/index.js
parent3336b2356ee6152d9c6ae59bd9b87ccbc0958407 (diff)
node: updatemain
Diffstat (limited to 'node_modules/gather-stream/index.js')
-rw-r--r--node_modules/gather-stream/index.js44
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;
-}