Function query_stream 

pub async fn query_stream(
    prompt: InputPrompt,
    options: Option<ClaudeAgentOptions>,
    transport: Option<Box<dyn Transport>>,
) -> Result<BoxStream<'static, Result<Message>>>

Sends a one-off query and returns responses as a stream.

The returned stream yields parsed Message values as they arrive.

The stream is Send and can be consumed from any tokio task.

Example

use claude_code::{query_stream, InputPrompt};
use futures::StreamExt;

    let mut stream = query_stream(
    InputPrompt::Text("Summarize Rust ownership".to_string()),
    None,
    None,
    )
    .await?;

    let _ = stream.next().await;