Method createPendingWrite

src/push.ts:287–315

* Create a pending write promise, optionally racing against a signal. * If the signal fires, the entry is removed from pendingWrites and the * promise rejects. Signal listeners are cleaned up on normal resolution.

(chunks: Uint8Array[], signal?: AbortSignal)

   * promise rejects. Signal listeners are cleaned up on normal resolution.
   */
  private createPendingWrite(chunks: Uint8Array[], signal?: AbortSignal): Promise<void> {
    return new Promise<void>((resolve, reject) => {
      const entry: PendingWrite = { chunks, resolve, reject };
      this.pendingWrites.push(entry);

      if (!signal) return;

      const onAbort = () => {
        // Remove from queue so it doesn't occupy a slot
        const idx = this.pendingWrites.indexOf(entry);
        if (idx !== -1) this.pendingWrites.removeAt(idx);
        reject(signal.reason ?? new DOMException('Aborted', 'AbortError'));
      };

      // Wrap resolve/reject to clean up signal listener
      const origResolve = entry.resolve;
      const origReject = entry.reject;
      entry.resolve = () => {
        signal.removeEventListener('abort', onAbort);
        origResolve();
      };
      entry.reject = (reason: Error) => {
        signal.removeEventListener('abort', onAbort);
        origReject(reason);
      };

      signal.addEventListener('abort', onAbort, { once: true });
    });
  }

  /**
   * Signal end of stream. Returns total bytes written.