Function query_stream 

pub async fn query_stream(
    config: ClientConfig,
) -> Result<impl Stream<Item = Result<Message>>>

Run a streaming query against Claude Code, yielding messages as they arrive.

Returns a Stream of Message values. The stream ends when the CLI emits a Result message.

Example

use claude_cli_sdk::{query_stream, ClientConfig, Message};
use tokio_stream::StreamExt;

let config = ClientConfig::builder()
    .prompt("Explain async/await in Rust")
    .build();
let mut stream = query_stream(config).await?;
tokio::pin!(stream);

while let Some(msg) = stream.next().await {
    let msg = msg?;
    if let Some(text) = msg.assistant_text() {
        print!("{text}");
    }
}