Function consume

out/cli.cjs:56186–56209

(stream4, type2)

      }
    };
    function isLocked(self2) {
      return self2[kBody] && self2[kBody].locked === true || self2[kConsume];
    }
    function isUnusable(self2) {
      return util4.isDisturbed(self2) || isLocked(self2);
    }
    async function consume(stream4, type2) {
      if (isUnusable(stream4)) {
        throw new TypeError("unusable");
      }
      assert2(!stream4[kConsume]);
      return new Promise((resolve, reject) => {
        stream4[kConsume] = {
          type: type2,
          stream: stream4,
          resolve,
          reject,
          length: 0,
          body: []
        };
        stream4.on("error", function(err) {
          consumeFinish(this[kConsume], err);
        }).on("close", function() {
          if (this[kConsume].body !== null) {
            consumeFinish(this[kConsume], new RequestAbortedError());
          }
        });