Streaming & resume

SSE framing, heartbeats, reconnect with seq

Streaming & resume

POST /chat streams AG-UI SSE; GET /chat/:runId/resume?since=<seq> replays.

const res = await fetch('/api/persona/chat', { method: 'POST', body: JSON.stringify({ agentId, messages, threadId }) });const runId = res.headers.get('x-persona-run-id')!;// ... drop after N frames, lastSeq = Nconst resumed = await fetch(`/api/persona/chat/${runId}/resume?since=${lastSeq}`);

const res = await fetch('/api/persona/chat', { method: 'POST', body: JSON.stringify({ agentId, messages, threadId }) });const runId = res.headers.get('x-persona-run-id')!;// ... drop after N frames, lastSeq = Nconst resumed = await fetch(`/api/persona/chat/${runId}/resume?since=${lastSeq}`);

Heartbeat comment : heartbeat every heartbeatIntervalMs (default 15000) during gaps so proxies don't kill idle streams. See .

Single-process/in-memory only — sticky sessions needed behind a load balancer. See sdk/runtime/README.md:298 for multi-instance RunBroker plan (issue #229).

Resolve user

CreateRuntimeOptions — @personaai/runtime