()
| 584 | } |
| 585 | |
| 586 | private decrementPendingWrites(): void { |
| 587 | this.pendingWriteCount-- |
| 588 | if (this.pendingWriteCount === 0) { |
| 589 | // Resolve all waiting flush promises |
| 590 | for (const resolve of this.flushResolvers) { |
| 591 | resolve() |
| 592 | } |
| 593 | this.flushResolvers = [] |
| 594 | } |
| 595 | } |
| 596 | |
| 597 | private async trackWrite<T>(fn: () => Promise<T>): Promise<T> { |
| 598 | this.incrementPendingWrites() |