Function flush

src/renderer/src/stores/persistenceQueue.ts:111–142

(key: TKey)

  }

  async function flush(key: TKey): Promise<void> {
    const timer = timers.get(key)
    if (timer) {
      clearTimeout(timer)
      timers.delete(key)
    }

    const inflight = writing.get(key)
    if (inflight) {
      await inflight
    }

    const task = pending.get(key)
    if (!task) return

    pending.delete(key)
    firstQueueTime.delete(key)

    const writePromise = retryWithBackoff(
      () => persistFn(key, task.data),
      maxRetries,
      initialRetryDelay,
      `persist ${key}`
    )

    writing.set(key, writePromise)
    try {
      await writePromise
    } finally {
      writing.delete(key)
    }
  }

  async function flushAll(): Promise<void> {
    const keys = Array.from(pending.keys())