MCPcopy Create free account
hub / github.com/QodeXcli/QodeX / drain

Method drain

src/bot/stream-pump.ts:45–47  ·  view source on GitHub ↗

Drain any throttle-deferred text — call this on a timer between pushes.

()

Source from the content-addressed store, hash-verified

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); }

Callers 1

runOneMethod · 0.95

Calls 1

flushMethod · 0.95

Tested by

no test coverage detected