Function query_from_stream 

pub async fn query_from_stream<S>(
    prompt: S,
    options: Option<ClaudeAgentOptions>,
    transport: Option<Box<dyn Transport>>,
) -> Result<Vec<Message>>
where
    S: Stream<Item = Value> + Unpin,

Sends a one-off query using streamed JSON input messages.

This is a Rust-idiomatic equivalent of Python’s AsyncIterable prompt mode.

Example

use claude_code::{query_from_stream, ClaudeAgentOptions};
use futures::stream;
use serde_json::json;

    let messages = query_from_stream(
    stream::iter(vec![json!({"type":"user","message":{"role":"user","content":"hello"}})]),
    Some(ClaudeAgentOptions::default()),
    None,
    )
    .await?;

    assert!(!messages.is_empty());