Drain any throttle-deferred text — call this on a timer between pushes.
()
| 43 | |
| 44 | /** Drain any throttle-deferred text — call this on a timer between pushes. */ |
| 45 | async drain(): Promise<void> { |
| 46 | if (this.dirty && this.io.now() - this.lastFlushAt >= this.io.minIntervalMs) await this.flush(false); |
| 47 | } |
| 48 | |
| 49 | /** Force the final state out, regardless of throttle. */ |
| 50 | async finish(): Promise<void> { await this.flush(true); } |