Method #resolvePendingWrites

lib/internal/streams/iter/push.js:493–507

()

  }

  #resolvePendingWrites() {
    while (this.#pendingWrites.length > 0 &&
          this.#slots.length < this.#highWaterMark) {
      const pending = this.#pendingWrites.shift();
      this.#slots.push(pending.chunks);
      for (let i = 0; i < pending.chunks.length; i++) {
        this.#bytesWritten += TypedArrayPrototypeGetByteLength(pending.chunks[i]);
      }
      pending.resolve();
    }

    if (this.#slots.length < this.#highWaterMark) {
      this.#resolvePendingDrains(true);
    }
  }

  #resolvePendingDrains(canWrite) {
    const drains = this.#pendingDrains;