()
| 622 | } |
| 623 | |
| 624 | private decrementPendingWrites(): void { |
| 625 | this.pendingWriteCount-- |
| 626 | if (this.pendingWriteCount === 0) { |
| 627 | // Resolve all waiting flush promises |
| 628 | for (const resolve of this.flushResolvers) { |
| 629 | resolve() |
| 630 | } |
| 631 | this.flushResolvers = [] |
| 632 | } |
| 633 | } |
| 634 | |
| 635 | private async trackWrite<T>(fn: () => Promise<T>): Promise<T> { |
| 636 | this.incrementPendingWrites() |