@internal Reset flush/queue state for testing.
()
| 571 | |
| 572 | /** @internal Reset flush/queue state for testing. */ |
| 573 | _resetFlushState(): void { |
| 574 | this.pendingWriteCount = 0 |
| 575 | this.flushResolvers = [] |
| 576 | if (this.flushTimer) clearTimeout(this.flushTimer) |
| 577 | this.flushTimer = null |
| 578 | this.activeDrain = null |
| 579 | this.writeQueues = new Map() |
| 580 | } |
| 581 | |
| 582 | private incrementPendingWrites(): void { |
| 583 | this.pendingWriteCount++ |
no outgoing calls
no test coverage detected