Function WritableStreamFinishErroring

out/cli.cjs:12335–12364

(stream4)

        }
      }
      function WritableStreamFinishErroring(stream4) {
        stream4._state = "errored";
        stream4._writableStreamController[ErrorSteps]();
        const storedError = stream4._storedError;
        stream4._writeRequests.forEach((writeRequest) => {
          writeRequest._reject(storedError);
        });
        stream4._writeRequests = new SimpleQueue();
        if (stream4._pendingAbortRequest === void 0) {
          WritableStreamRejectCloseAndClosedPromiseIfNeeded(stream4);
          return;
        }
        const abortRequest = stream4._pendingAbortRequest;
        stream4._pendingAbortRequest = void 0;
        if (abortRequest._wasAlreadyErroring) {
          abortRequest._reject(storedError);
          WritableStreamRejectCloseAndClosedPromiseIfNeeded(stream4);
          return;
        }
        const promise = stream4._writableStreamController[AbortSteps](abortRequest._reason);
        uponPromise(promise, () => {
          abortRequest._resolve();
          WritableStreamRejectCloseAndClosedPromiseIfNeeded(stream4);
          return null;
        }, (reason) => {
          abortRequest._reject(reason);
          WritableStreamRejectCloseAndClosedPromiseIfNeeded(stream4);
          return null;
        });
      }
      function WritableStreamFinishInFlightWrite(stream4) {
        stream4._inFlightWriteRequest._resolve(void 0);
        stream4._inFlightWriteRequest = void 0;