fix(server): close event stream when requiresInput/requiresAuth force isFinal

[chopmob-cloud]

Fixes #975.

Problem

AgentEmitter#requiresInput(message, isFinal=true) (and requiresAuth(..., isFinal=true)) set the internal terminalStateReached flag but never completed the stream. The emitted TaskStatusUpdateEvent#isFinal() is derived from the task state (status.state().isFinal()), which is false for the interrupted INPUT_REQUIRED / AUTH_REQUIRED states, so EventConsumer kept the SSE / Flow.Publisher open. The isFinal argument therefore only blocked further updates; it could not end the stream, and connections an agent asked to release stayed open.

Fix

When the caller forces finality on a non-terminal state, enqueue the existing QueueClosedEvent after the status event:

if (isFinal && !state.isFinal()) {
    eventQueue.enqueueEvent(new QueueClosedEvent(taskId));
}

EventConsumer already treats QueueClosedEvent as a stream-terminating event, so the status event is delivered and then the stream completes, letting the client resume via a new request. This uses the SDK's own close path and touches neither the event record nor the proto. Interrupted states still stay open by default (#756); only an explicit isFinal=true closes them. Terminal states are unaffected (their event's isFinal() is already true, and the !state.isFinal() guard skips them).

Also removes a stale .isFinal(false) call from the emitEvent Javadoc, since the builder no longer exposes it.

Tests

• Updated the four interrupted+final tests to assert the trailing QueueClosedEvent via a backward-compatible expectStreamClose overload of the existing helper.
• Verified on JDK 17: server-common suite 412/412 pass; with the fix reverted, the four forced-final tests fail (confirming they exercise the behavior).

Note on approach

This implements the "wire isFinal to actually close the stream" option. If you'd rather treat interrupted streams as always staying open and have isFinal on requiresInput/requiresAuth deprecated/documented instead, I'm happy to switch to that.

[gemini-code-assist]

Code Review

This pull request introduces explicit stream closure handling in AgentEmitter when finality is forced on a non-terminal state by enqueuing a QueueClosedEvent. This ensures the stream completes and allows clients to resume via a new request. The corresponding unit tests in AgentEmitterTest have been updated to verify that QueueClosedEvent is correctly emitted under these conditions. I have no feedback to provide as the implementation is correct and well-tested.

Important

The consumer version of Gemini Code Assist on GitHub is being sunset. Starting June 18, 2026, new organization installations will be blocked, and all code review activity will officially cease on July 17, 2026.
For more details on the timeline and next steps, please review the Help Documentation.

[kabir]

/gemini review

[gemini-code-assist]

Code Review

This pull request introduces the emission of a QueueClosedEvent in AgentEmitter when a final status is forced on a non-terminal (interrupted) task state, ensuring the event stream is explicitly closed so clients can resume via a new request. The corresponding unit tests in AgentEmitterTest have been updated to verify this behavior. I have no feedback to provide as there are no review comments.

Important

The consumer version of Gemini Code Assist on GitHub is being sunset. Starting June 18, 2026, new organization installations will be blocked, and all code review activity will officially cease on July 17, 2026.
For more details on the timeline and next steps, please review the Help Documentation.