Struct StdioTransport 

pub struct StdioTransport { /* private fields */ }

MCP transport over stdio — spawns a subprocess and pipes JSON-RPC messages.

Implementations

impl StdioTransport

pub async fn spawn(command: &str) -> Result<Self, TransportError>

Spawn a child process from a shell command string.

The command is split using shell word-splitting rules (handles quotes). stdin and stdout are piped for JSON-RPC communication; stderr is inherited so the user can see server logs.

pub async fn spawn_quiet(command: &str) -> Result<Self, TransportError>

Spawn a child process with stderr suppressed.

Used for disposable sessions where server startup messages would clutter the terminal output.

pub fn set_read_timeout(&mut self, timeout: Duration)

Set the read timeout for this transport.

pub fn command(&self) -> &str

Get the original command string (for reconnection).

Trait Implementations

impl Transport for StdioTransport

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

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

Write a raw message string without reading a response. Used for notifications and other one-way messages.

fn request_raw<'life0, 'life1, 'async_trait>( &'life0 mut self, message: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, TransportError>> + Send + 'async_trait>>

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

Write a raw message string and read back one response line. Returns None if the response line is empty.

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

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

Shut down the transport gracefully.

fn capabilities(&self) -> TransportCapabilities

Capability metadata for this transport implementation.

fn send_request<'life0, 'life1, 'async_trait>( &'life0 mut self, req: &'life1 JsonRpcRequest, ) -> Pin<Box<dyn Future<Output = Result<JsonRpcResponse, TransportError>> + Send + 'async_trait>>

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

Send a typed JSON-RPC request and get the parsed response.

fn send_notification<'life0, 'life1, 'async_trait>( &'life0 mut self, notif: &'life1 JsonRpcNotification, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

Send a JSON-RPC notification (write-only, no response expected).

fn send_raw<'life0, 'life1, 'async_trait>( &'life0 mut self, message: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, TransportError>> + Send + 'async_trait>>

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

Send a raw string and read one response. Convenience alias for the fuzzer.