diff --git a/pkg/agent/loop.go b/pkg/agent/loop.go index 1889ba322..cb972764c 100644 --- a/pkg/agent/loop.go +++ b/pkg/agent/loop.go @@ -803,7 +803,7 @@ func (al *AgentLoop) runLLMIteration( // Check if both the provider and channel support streaming streamProvider, providerCanStream := agent.Provider.(providers.StreamingProvider) var streamer bus.Streamer - if providerCanStream && !constants.IsInternalChannel(opts.Channel) { + if providerCanStream && opts.SendResponse && !constants.IsInternalChannel(opts.Channel) { streamer, _ = al.bus.GetStreamer(ctx, opts.Channel, opts.ChatID) }