Function consume

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

(stream, type)

        return util.isDisturbed(self) || isLocked(self);
      }
      function consume(stream, type) {
        return __async(this, null, function* () {
          assert(!stream[kConsume]);
          return new Promise((resolve2, reject) => {
            var _a;
            if (isUnusable(stream)) {
              const rState = stream._readableState;
              if (rState.destroyed && rState.closeEmitted === false) {
                stream.on("error", (err) => {
                  reject(err);
                }).on("close", () => {
                  reject(new TypeError("unusable"));
                });
              } else {
                reject((_a = rState.errored) != null ? _a : new TypeError("unusable"));
              }
            } else {
              queueMicrotask(() => {
                stream[kConsume] = {
                  type,
                  stream,
                  resolve: resolve2,
                  reject,
                  length: 0,
                  body: []
                };
                stream.on("error", function(err) {
                  consumeFinish(this[kConsume], err);
                }).on("close", function() {
                  if (this[kConsume].body !== null) {
                    consumeFinish(this[kConsume], new RequestAbortedError());
                  }
                });
                consumeStart(stream[kConsume]);
              });
            }
          });
        });
      }
      function consumeStart(consume2) {
        if (consume2.body === null) {
          return;