diff --git a/src/core/bot/mod.rs b/src/core/bot/mod.rs index cef79d81..6292c054 100644 --- a/src/core/bot/mod.rs +++ b/src/core/bot/mod.rs @@ -859,17 +859,7 @@ impl BotOrchestrator { } } - let stream_timeout = tokio::time::Duration::from_secs(60); -'stream_loop: loop { - let chunk_result = tokio::time::timeout(stream_timeout, stream_rx.recv()).await; - let chunk = match chunk_result { - Ok(Some(c)) => c, - Ok(None) => break 'stream_loop, - Err(_) => { - error!("LLM stream timeout after {}s - aborting response", stream_timeout.as_secs()); - break 'stream_loop - } - }; + while let Some(chunk) = stream_rx.recv().await { // ===== GENERIC TOOL EXECUTION ===== // Add chunk to tool_call_buffer and try to parse