Struct AsyncClient 

pub struct AsyncClient { /* private fields */ }

Asynchronous client for communicating with Claude

Implementations

impl AsyncClient

pub fn new(child: Child) -> Result<Self>

Create a new async client from a tokio Child process

pub async fn with_defaults() -> Result<Self>

Create a client with default settings (using logic from start_claude)

pub async fn with_model(model: &str) -> Result<Self>

Create a client with a specific model

pub async fn from_builder(builder: ClaudeCliBuilder) -> Result<Self>

Create a client from a custom builder

pub async fn resume_session(session_uuid: Uuid) -> Result<Self>

Resume a previous session by UUID This creates a new client that resumes an existing session

pub async fn resume_session_with_model( session_uuid: Uuid, model: &str, ) -> Result<Self>

Resume a previous session with a specific model

pub async fn query(&mut self, text: &str) -> Result<Vec<ClaudeOutput>>

Send a query and collect all responses until Result message This is the simplified version that collects all responses

pub async fn query_with_session( &mut self, text: &str, session_id: Uuid, ) -> Result<Vec<ClaudeOutput>>

Send a query with a custom session ID and collect all responses

pub async fn query_stream(&mut self, text: &str) -> Result<ResponseStream<'_>>

Send a query and return an async iterator over responses Returns a stream that yields ClaudeOutput until Result message is received

pub async fn query_stream_with_session( &mut self, text: &str, session_id: Uuid, ) -> Result<ResponseStream<'_>>

Send a query with session ID and return an async iterator over responses

pub async fn send(&mut self, input: &ClaudeInput) -> Result<()>

Send a ClaudeInput directly

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

Try to receive a single response

pub fn is_alive(&mut self) -> bool

Check if the Claude process is still running

pub async fn shutdown(self) -> Result<()>

Gracefully shutdown the client

pub fn pid(&self) -> Option<u32>

Get the process ID

pub fn take_stderr(&mut self) -> Option<BufReader<ChildStderr>>

Take the stderr reader (can only be called once)

pub fn session_uuid(&self) -> Result<Uuid>

Get the session UUID if available Returns an error if no response has been received yet

pub async fn ping(&mut self) -> bool

Test if the Claude connection is working by sending a ping message Returns true if Claude responds with “pong”, false otherwise

Trait Implementations

impl Drop for AsyncClient

fn drop(&mut self)

Executes the destructor for this type.