Struct SubprocessCLITransport 

pub struct SubprocessCLITransport { /* private fields */ }

Subprocess transport using Claude Code CLI

Implementations

impl SubprocessCLITransport

pub fn new( prompt: &str, options: ClaudeCodeOptions, cli_path: Option<&str>, ) -> Result<Self, ClaudeSDKError>

Create a new subprocess transport

pub fn with_safety_limits(self, limits: SafetyLimits) -> Self

Set custom safety limits for this transport

pub fn try_parse_json_buffer( &mut self, ) -> Option<Result<HashMap<String, Value>, ClaudeSDKError>>

Try to parse accumulated JSON buffer, handling multiline JSON

pub fn process_line( &mut self, line: String, ) -> Option<Result<HashMap<String, Value>, ClaudeSDKError>>

Process a single line and update JSON buffer state

Trait Implementations

impl Transport for SubprocessCLITransport

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

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

Start subprocess

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

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

Terminate subprocess

fn receive_messages( &mut self, ) -> Pin<Box<dyn Stream<Item = Result<HashMap<String, Value>, ClaudeSDKError>> + Send + '_>>

Receive messages from CLI

fn is_connected(&self) -> bool

Check if subprocess is running

fn send_request<'life0, 'async_trait>( &'life0 mut self, _messages: Vec<HashMap<String, Value>>, _options: HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = Result<(), ClaudeSDKError>> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait,

Send request to Claude (not used for CLI transport - args passed via command line)