pub async fn consume_llm_stream_with_context(
stream: LLMStream,
event_tx: &Sender<AgentEvent>,
cancel_token: &CancellationToken,
session_id: &str,
timeout_context: &StreamTimeoutContext,
) -> Result<StreamHandlingOutput, AgentError>