diff --git a/src/main/runtime/rpc/methods/structured-sessions/subscriptions/structured-agent-session-subscribe-method.ts b/src/main/runtime/rpc/methods/structured-sessions/subscriptions/structured-agent-session-subscribe-method.ts index 8e3046fb5cc..37131187ad3 100644 --- a/src/main/runtime/rpc/methods/structured-sessions/subscriptions/structured-agent-session-subscribe-method.ts +++ b/src/main/runtime/rpc/methods/structured-sessions/subscriptions/structured-agent-session-subscribe-method.ts @@ -29,7 +29,7 @@ export const STRUCTURED_AGENT_SESSION_SUBSCRIBE_METHOD = defineStreamingMethod({ if (stream.isClosed()) { return } - // Resolve after opening snapshot/missed batch; a racing close disposes the bound stream. + // Resolve once registered; the opening snapshot follows on the stream. A racing close disposes it. dispose = await host.subscribe({ commandsOnRequest: clientRequestsCommands(ctx), readsCurrentRequests: clientReadsCurrentRequests(ctx),