Class EventQueue

app/utils/PeerDataChannel.ts:246–262

}

export class EventQueue<T> {
  private tail: Promise<void> = Promise.resolve()
  private handler: (e: T) => Promise<void>

  constructor(handler: (e: T) => Promise<void>) {
    this.handler = handler
  }

  public enqueue(e: T): void {
    // 每次把新任务链到上一个任务后面
    this.tail = this.tail
      .then(() => this.handler(e))
      .catch((error) => {
        console.error('Error processing event:', error)
      })
  }
}