Function getOrCreateQueue

src/renderer/src/stores/persistenceQueue.ts:217–228

(
  queueId: string,
  factory: () => PersistenceQueue<string, TData>
)

}

function getOrCreateQueue<TData>(
  queueId: string,
  factory: () => PersistenceQueue<string, TData>
): PersistenceQueue<string, TData> {
  registerFlushListener()

  if (!queues.has(queueId)) {
    queues.set(queueId, factory() as PersistenceQueue<string, unknown>)
  }

  return queues.get(queueId)! as PersistenceQueue<string, TData>
}

function accountQueueId(accountId: string, entity: string): string {
  return `account:${accountId}:${entity}`