Method finalizeEventChannel

pkg/runtime/loop.go:197–218

finalizeEventChannel performs cleanup at the end of a RunStream goroutine: emits the StreamStopped event, fires hooks, records telemetry, restores the previous elicitation channel, and closes the events channel. reason is one of the turnEndReason* constants and classifies how the stream ended (e.g.

(ctx context.Context, sess *session.Session, reason string, prevElicitationCh, events chan Event)

// Consumers must rely on the channel close, not on receiving StreamStopped, as
// the guaranteed terminal signal.
func (r *LocalRuntime) finalizeEventChannel(ctx context.Context, sess *session.Session, reason string, prevElicitationCh, events chan Event) {
	a := r.resolveSessionAgent(sess)

	if ctx.Err() != nil && reason == "" {
		reason = turnEndReasonCanceled
	}

	// Best-effort, non-blocking on purpose: a blocking send here reintroduces
	// the #3070 teardown deadlock. See the doc comment for the ordering and
	// delivery contract.
	nonBlocking(&channelSink{ch: events}).Emit(StreamStopped(sess.ID, a.Name(), reason))

	// Execute session end hooks with a context that won't be cancelled so
	// cleanup hooks run even when the stream was interrupted (e.g. Ctrl+C).
	r.executeSessionEndHooks(context.WithoutCancel(ctx), sess, a)

	r.executeOnUserInputHooks(ctx, sess.ID, "stream stopped")

	r.telemetry.RecordSessionEnd(ctx)

	r.elicitation.restoreAndClose(events, prevElicitationCh)
}

// RunStream starts the agent's interaction loop and returns a channel of events.
// The returned channel is closed when the loop terminates (success, error, or