Function consume

github-actions/saucelabs/set-saucelabs-env.js:9798–9836

(stream, type)

          return this[kBody];
        }
        dump(opts) {
          return __async(this, null, function* () {
            let limit = Number.isFinite(opts == null ? void 0 : opts.limit) ? opts.limit : 128 * 1024;
            const signal = opts == null ? void 0 : opts.signal;
            if (signal != null && (typeof signal !== "object" || !("aborted" in signal))) {
              throw new InvalidArgumentError("signal must be an AbortSignal");
            }
            signal == null ? void 0 : signal.throwIfAborted();
            if (this._readableState.closeEmitted) {
              return null;
            }
            return yield new Promise((resolve2, reject) => {
              if (this[kContentLength] > limit) {
                this.destroy(new AbortError());
              }
              const onAbort = () => {
                var _a;
                this.destroy((_a = signal.reason) != null ? _a : new AbortError());
              };
              signal == null ? void 0 : signal.addEventListener("abort", onAbort);
              this.on("close", function() {
                var _a;
                signal == null ? void 0 : signal.removeEventListener("abort", onAbort);
                if (signal == null ? void 0 : signal.aborted) {
                  reject((_a = signal.reason) != null ? _a : new AbortError());
                } else {
                  resolve2(null);
                }
              }).on("error", noop).on("data", function(chunk) {
                limit -= chunk.length;
                if (limit <= 0) {
                  this.destroy();
                }
              }).resume();
            });
          });
        }
      };
      function isLocked(self) {
        return self[kBody] && self[kBody].locked === true || self[kConsume];
      }
      function isUnusable(self) {