Function ReadableStreamCancel

out/cli.cjs:14133–14152

(stream4, reason)

        return true;
      }
      function ReadableStreamCancel(stream4, reason) {
        stream4._disturbed = true;
        if (stream4._state === "closed") {
          return promiseResolvedWith(void 0);
        }
        if (stream4._state === "errored") {
          return promiseRejectedWith(stream4._storedError);
        }
        ReadableStreamClose(stream4);
        const reader = stream4._reader;
        if (reader !== void 0 && IsReadableStreamBYOBReader(reader)) {
          const readIntoRequests = reader._readIntoRequests;
          reader._readIntoRequests = new SimpleQueue();
          readIntoRequests.forEach((readIntoRequest) => {
            readIntoRequest._closeSteps(void 0);
          });
        }
        const sourceCancelPromise = stream4._readableStreamController[CancelSteps](reason);
        return transformPromiseWith(sourceCancelPromise, noop2);
      }
      function ReadableStreamClose(stream4) {
        stream4._state = "closed";
        const reader = stream4._reader;