diff --git a/pkg/agent/loop.go b/pkg/agent/loop.go index 8a0b7abd1..785fe1e70 100644 --- a/pkg/agent/loop.go +++ b/pkg/agent/loop.go @@ -740,7 +740,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) }