Struct ChatStream 

pub struct ChatStream { /* private fields */ }

Async stream of ChatResponse events from a streaming chat request.

Each next yields one NDJSON line deserialized as ChatResponse. When the server closes the body, next returns None.

Examples

use ollama_oxide::{ChatMessage, ChatRequest, OllamaApiAsync, OllamaClient};

#[tokio::main]
async fn main() -> ollama_oxide::Result<()> {
    let client = OllamaClient::default()?;
    let request = ChatRequest::new("qwen3:0.6b", [ChatMessage::user("Hi!")]);
    let stream = client.chat_stream(&request).await?;
    while let Some(event) = stream.next().await {
        let chunk = event?;
        if let Some(s) = chunk.content() {
            print!("{}", s);
        }
    }
    Ok(())
}

Implementations

impl ChatStream

pub async fn next(&self) -> Option<Result<ChatResponse>>

Returns the next event, or None when the stream has ended.

pub async fn collect(self) -> Result<Vec<ChatResponse>>

Collects all events into a vector, stopping on the first error.