Function consumeStart

github-actions/browserstack/set-browserstack-env.js:9837–9863

(consume2)

                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) {
        return util.isDisturbed(self) || isLocked(self);
      }
      function consume(stream, type) {
        return __async(this, null, function* () {
          assert(!stream[kConsume]);
          return new Promise((resolve2, reject) => {