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