Function consumeStart

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

(consume2)

      };
      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) => {
            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: []