diff --git a/internal/llm/agent/agent.go b/internal/llm/agent/agent.go index 13b65cccc79ded8f1f7267063898216defb38908..b1d9dd8c98420aa963f6e6fa5df8fbefc5a632b2 100644 --- a/internal/llm/agent/agent.go +++ b/internal/llm/agent/agent.go @@ -374,10 +374,7 @@ func (a *agent) Run(ctx context.Context, sessionID string, content string, attac a.activeRequests.Del(sessionID) cancel() a.Publish(pubsub.CreatedEvent, result) - select { - case events <- result: - case <-genCtx.Done(): - } + events <- result close(events) }() return events, nil