Method constructor

lib/internal/streams/iter/push.js:89–113

(options = { __proto__: null })

  #abortHandler;

  constructor(options = { __proto__: null }) {
    const {
      highWaterMark = kPushDefaultHWM,
      backpressure = 'strict',
      signal,
    } = options;
    validateInteger(highWaterMark, 'options.highWaterMark');
    validateBackpressure(backpressure);
    if (signal !== undefined) {
      validateAbortSignal(signal, 'options.signal');
    }
    this.#highWaterMark = clampHWM(highWaterMark);
    this.#backpressure = backpressure;
    this.#signal = signal;
    this.#abortHandler = undefined;

    if (this.#signal) {
      this.#abortHandler = () => {
        this.fail(isError(this.#signal.reason) ?
          this.#signal.reason :
          lazyDOMException('Aborted', 'AbortError'));
      };
      onSignalAbort(this.#signal, this.#abortHandler);
    }
  }

  // ===========================================================================
  // Writer Methods