AsyncTaskQueue.ts

class AsyncTaskQueue {
  private tasks: (() => Promise<void>)[] = [];
  private isRunning = false;

  public addTask(task: () => Promise<void>, signal?: AbortSignal): Promise<void> {
    return new Promise((resolve, reject) => {
      const wrappedTask = async () => {
        if (signal?.aborted) return reject(new Error('Task aborted'));
        try {
          await task();
          resolve();
        } catch (error) {
          reject(error);
        }
      };

      this.tasks.push(wrappedTask);
      this.runNext();
    });
  }

  private async runNext() {
    if (this.isRunning || this.tasks.length === 0) return;
    this.isRunning = true;

    const task = this.tasks.shift();
    await task();

    this.isRunning = false;
    this.runNext();
  }
}