Method fail

lib/internal/streams/iter/broadcast.js:640–648

(reason)

  }

  fail(reason) {
    if (this.#isClosedOrAborted()) return;
    this.#aborted = true;
    this.#closed = PromiseResolve(this.#totalBytes);
    const error = reason ?? new ERR_INVALID_STATE.TypeError('Failed');
    this.#rejectPendingWrites(error);
    this.#rejectPendingDrains(error);
    this.#broadcast[kAbort](error);
  }

  [SymbolAsyncDispose]() {
    this.fail();