Skip to main content

consume_llm_stream

Function consume_llm_stream 

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