Method push

src/bot/stream-pump.ts:38–42

Append streamed text; flush now if the throttle window elapsed, else mark dirty.

(delta: string)

  /** Append streamed text; flush now if the throttle window elapsed, else mark dirty. */
  async push(delta: string): Promise<void> {
    if (delta) this.buf += delta;
    if (this.io.now() - this.lastFlushAt >= this.io.minIntervalMs) await this.flush(false);
    else this.dirty = true;
  }

  /** Drain any throttle-deferred text — call this on a timer between pushes. */
  async drain(): Promise<void> {