Method subscribeChat

src/node/services/agentSession.ts:621–631

(listener: (event: AgentSessionChatEvent) => void)

  }

  async subscribeChat(listener: (event: AgentSessionChatEvent) => void): Promise<() => void> {
    this.assertNotDisposed("subscribeChat");
    assert(typeof listener === "function", "listener must be a function");

    const unsubscribe = this.onChatEvent(listener);
    await this.emitHistoricalEvents(listener);

    this.scheduleStartupRecovery();

    return unsubscribe;
  }

  async replayHistory(
    listener: (event: AgentSessionChatEvent) => void,