()
| 142 | } |
| 143 | |
| 144 | async function flushAll(): Promise<void> { |
| 145 | const keys = Array.from(pending.keys()) |
| 146 | await Promise.all(keys.map((key) => flush(key))) |
| 147 | } |
| 148 | |
| 149 | async function waitForWrites(): Promise<void> { |
| 150 | await Promise.all(Array.from(writing.values())) |