git.iko.soy/crush
on main help sign in
fix: fix goroutine panic due to waiting for channel for too long
d01ef3eAndrey Nering
internal/llm/agent/agent.go+4−1
compare with main
unifiedsplit
@@ -374,7 +374,10 @@ func (a *agent) Run(ctx context.Context, sessionID string, content string, attac
374 a.activeRequests.Del(sessionID)
374 a.activeRequests.Del(sessionID)
375 cancel()
375 cancel()
376 a.Publish(pubsub.CreatedEvent, result)
376 a.Publish(pubsub.CreatedEvent, result)
377+ select {
377− events <- result
378+ case events <- result:
379+ case <-genCtx.Done():
380+ }
378 close(events)
381 close(events)
379 }()
382 }()
380 return events, nil
383 return events, nil