Struct ClaudeSDKClient 

pub struct ClaudeSDKClient { /* private fields */ }

A stateful client for multi-turn conversations with the Claude CLI.

Unlike query() which is one-shot, the client maintains a connection and supports sending multiple queries, interrupts, and control commands.

Example

use claude_code_rs::{ClaudeAgentOptions, Message};
use claude_code_rs::client::ClaudeSDKClient;
use tokio_stream::StreamExt;

let mut client = ClaudeSDKClient::new(ClaudeAgentOptions::default());
client.connect(None).await?;

// First query.
client.query("What is Rust?", None).await?;
{
    let mut stream = client.receive_messages();
    while let Some(msg) = stream.next().await {
        let msg = msg?;
        if msg.is_result() { break; }
    }
} // Receiver auto-restores when `stream` drops.

// Follow-up query in same session.
client.query("How does ownership work?", None).await?;
// ...

client.disconnect().await?;

Implementations

impl ClaudeSDKClient

pub fn new(options: ClaudeAgentOptions) -> Self

pub fn add_mcp_server( &mut self, name: impl Into<String>, server: SdkMcpServer, ) -> Result<()>

Register an in-process MCP server by name.

Must be called before connect(). Returns an error if the client is already connected (servers are snapshot-cloned during connect).

pub async fn connect(&mut self, initial_prompt: Option<&str>) -> Result<()>

Connect to the Claude CLI. Optionally send an initial prompt.

pub async fn query(&self, prompt: &str, session_id: Option<&str>) -> Result<()>

Send a query/prompt. Optionally provide a session_id for resuming.

pub fn receive_messages(&mut self) -> MessageStream<'_>

Get a stream of messages from the current query.

Messages flow until a ResultMessage signals end of turn. The receiver is automatically restored when the returned MessageStream is dropped, so the client remains usable for follow-up queries.

pub async fn receive_response(&mut self) -> Result<Vec<Message>>

Collect all messages until the next ResultMessage.

pub async fn interrupt(&self) -> Result<Value>

Send an interrupt command.

pub async fn set_permission_mode(&self, mode: &str) -> Result<Value>

Change the permission mode.

pub async fn set_model(&self, model: &str) -> Result<Value>

Change the model.

pub async fn rewind_files(&self, user_message_id: &str) -> Result<Value>

Rewind file changes to a specific user message.

pub async fn get_mcp_status(&self) -> Result<Value>

Get MCP server status.

pub async fn get_server_info(&self) -> Option<Value>

Get server info from the init handshake.

pub async fn disconnect(&mut self) -> Result<()>

Disconnect from the CLI.

pub fn is_connected(&self) -> bool

Check if connected.