class AsyncQueue<T> {
  private queue: T[] = [];
  private processing = false;
  
  async enqueue(item: T, processor: (item: T) => Promise<void>) {
    this.queue.push(item);
      await this.processQueue(processor);
    }
  }
  
  private async processQueue(processor: (item: T) => Promise<void>) {
    this.processing = true;
    while (this.queue.length > 0) {
      await processor(item);
    }
    this.processing = false;
  }
}
export { AsyncQueue };