( queue: PersistenceQueue<TKey, TData> )
| 236 | } |
| 237 | |
| 238 | async function flushQueue<TKey extends string, TData>( |
| 239 | queue: PersistenceQueue<TKey, TData> |
| 240 | ): Promise<void> { |
| 241 | await queue.flushAll() |
| 242 | await queue.waitForWrites() |
| 243 | } |
| 244 | |
| 245 | function mergePageFileMutation(current: PageFileMutation, next: PageFileMutation): PageFileMutation { |
| 246 | if (current.deletePage || next.deletePage) { |