Class DebounceQueue

packages/cli/src/dev-watch.ts:44–81

}

class DebounceQueue {
  private timer: NodeJS.Timeout | null = null
  private changes: Set<string> = new Set()
  private callback: (changes: Set<string>) => void

  constructor(
    callback: (changes: Set<string>) => void,
    private delay: number = 1000,
  ) {
    this.callback = callback
  }

  add(path: string): void {
    this.changes.add(path)

    if (this.timer) {
      clearTimeout(this.timer)
    }

    this.timer = setTimeout(() => {
      const currentChanges = new Set(this.changes)
      this.callback(currentChanges)
      this.changes.clear()
    }, this.delay)
  }

  size(): number {
    return this.changes.size
  }

  clear(): void {
    if (this.timer) {
      clearTimeout(this.timer)
      this.timer = null
    }
    this.changes.clear()
  }
}

export class DevWatchManager {
  private watcher: FSWatcher | null = null