()
| 367 | } |
| 368 | |
| 369 | export async function flushAllPersistenceQueues(): Promise<void> { |
| 370 | await Promise.all(Array.from(queues.values()).map((queue) => queue.dispose())) |
| 371 | } |
| 372 | |
| 373 | export async function resetPersistenceQueues(): Promise<void> { |
| 374 | await flushAllPersistenceQueues() |
no outgoing calls
no test coverage detected