Struct ChatResource 

pub struct ChatResource { /* private fields */ }

Streaming chat, stop, and HITL-decision operations scoped to one conversation. Obtain via [LlmrixClient::chat].

Implementations

impl ChatResource

pub async fn send<F>(&self, message: &str, handler: F) -> Result<()>

where F: FnMut(&StreamEvent) -> Result<()>,

Send a plain-text message and stream the agent’s response.

handler is called synchronously for each received StreamEvent. Return Err from the handler to abort streaming early.

client.chat(conv_id).send("Hello!", |event| {
    if let StreamEvent::MessageChunk(e) = event {
        print!("{}", e.content);
    }
    Ok(())
}).await?;

pub async fn send_request<F>(&self, req: ChatRequest, handler: F) -> Result<()>

where F: FnMut(&StreamEvent) -> Result<()>,

Send a fully-specified ChatRequest and stream the response. Use this overload to supply agent_id, metadata, or HITL decisions inline.

pub async fn stop(&self) -> Result<()>

Request the server to cancel the currently running chat turn. The in-flight send call will receive a Cancelled event before the stream closes.

pub async fn decide(&self, decisions: Vec<HitlDecision>) -> Result<()>

Submit HITL decisions to resume a paused agent run. Call this after receiving a HitlInterrupt event.