Struct StdioTransport 

pub struct StdioTransport { /* private fields */ }

Communicates with an MCP server via stdin/stdout of a child process. One JSON-RPC message per line (newline-delimited JSON, i.e. NDJSON protocol).

Implementations

impl StdioTransport

pub async fn new( command: &str, args: &[&str], env: Option<HashMap<String, String>>, ) -> Result<Self, McpError>

Spawn a child process and create a stdio transport.

pub fn with_timeout(self, request_timeout: Duration) -> Self

Override the per-request timeout. Default is DEFAULT_REQUEST_TIMEOUT (30 s).

Applies to each send() call independently — write + read + parse share the same budget. On timeout, send() returns McpError::Timeout and the next caller gets a fresh budget.

Trait Implementations

impl McpTransport for StdioTransport

fn send<'life0, 'async_trait>( &'life0 self, request: JsonRpcRequest, ) -> Pin<Box<dyn Future<Output = Result<JsonRpcResponse, McpError>> + Send + 'async_trait>>

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

Send a JSON-RPC request and receive the response.

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

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

Close the transport (kill child process, close HTTP connections, etc.).