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