Struct SubprocessTransport 

pub struct SubprocessTransport { /* private fields */ }

Subprocess-based transport for Claude CLI

Implementations

impl SubprocessTransport

pub fn new(options: ClaudeCodeOptions) -> Result<Self>

Create a new subprocess transport

pub fn subscribe_messages( &self, ) -> Option<Pin<Box<dyn Stream<Item = Result<Message>> + Send + 'static>>>

Subscribe to messages without borrowing self (for lock-free consumption)

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

Receive SDK control requests

pub fn take_sdk_control_receiver(&mut self) -> Option<Receiver<Value>>

Take the SDK control receiver (can only be called once)

pub fn with_cli_path( options: ClaudeCodeOptions, cli_path: impl Into<PathBuf>, ) -> Self

Create with a specific CLI path

pub fn set_close_stdin_after_prompt(&mut self, close: bool)

Set whether to close stdin after sending the initial prompt

pub fn for_print_mode( options: ClaudeCodeOptions, _prompt: String, ) -> Result<Self>

Create transport for simple print mode (one-shot query)

Trait Implementations

impl Drop for SubprocessTransport

fn drop(&mut self)

Executes the destructor for this type.

impl Transport for SubprocessTransport

fn as_any_mut(&mut self) -> &mut dyn Any

Get self as Any for downcasting

fn connect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connect to the Claude CLI

fn send_message<'life0, 'async_trait>( &'life0 mut self, message: InputMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a message to Claude

fn receive_messages( &mut self, ) -> Pin<Box<dyn Stream<Item = Result<Message>> + Send + 'static>>

Receive messages from Claude as a stream

fn send_control_request<'life0, 'async_trait>( &'life0 mut self, request: ControlRequest, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a control request (e.g., interrupt)

fn receive_control_response<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<ControlResponse>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Receive control responses

fn send_sdk_control_request<'life0, 'async_trait>( &'life0 mut self, request: Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send an SDK control request (for control protocol)

fn send_sdk_control_response<'life0, 'async_trait>( &'life0 mut self, response: Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send an SDK control response

fn is_connected(&self) -> bool

Check if the transport is connected

fn disconnect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Disconnect from the Claude CLI

fn take_sdk_control_receiver(&mut self) -> Option<Receiver<Value>>

Take the SDK control receiver, if supported by the transport Default implementation returns None for transports that do not support inbound control messages.

fn end_input<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Signal end of input stream (default: no-op)