Struct StdioTransport 

pub struct StdioTransport { /* private fields */ }

Unstable (feature: mcp-transport) — may change or be removed

Stdio transport for a spawned MCP server process.

Implementations

impl StdioTransport

pub fn spawn( command: &str, args: &[String], env: &HashMap<String, String>, cwd: Option<&str>, debug: bool, validator: Option<&dyn SpawnValidator>, ) -> Result<StdioTransport, Error>

Spawn a child process and return a connected transport.

validator, when Some, is invoked BEFORE the spawn with SpawnValidator::validate_command; an Err is converted to anyhow::Error and short-circuits the spawn. After the SDK’s hardcoded BLOCKED_ENV_VARS filter is applied, the validator’s SpawnValidator::sanitize_env runs over the remaining env so consumers can apply additional policy (path normalization, custom blocked vars, etc.).

None preserves the pre-validator behavior: only the SDK’s BLOCKED_ENV_VARS floor applies. Existing call sites pass None.

pub fn from_parts( child: Child, stdin: ChildStdin, stdout: ChildStdout, ) -> StdioTransport

Wrap an already-spawned child process. Used internally by the client to allow later take_child.

pub fn take_child(&mut self) -> Option<Child>

Take the child process out (for graceful shutdown via signal).

Trait Implementations

impl Debug for StdioTransport

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl McpTransport for StdioTransport

fn request<'life0, 'life1, 'async_trait>( &'life0 mut self, id: u64, json: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<RawJsonRpcMessage, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, StdioTransport: 'async_trait,

Send a JSON-RPC request and await the matching response.

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

where 'life0: 'async_trait, 'life1: 'async_trait, StdioTransport: 'async_trait,

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

fn set_inbound_handler( &mut self, handler: Box<dyn FnMut(RawJsonRpcMessage) -> Option<Value> + Send + Sync>, )

Install (or replace) the inbound handler. Called by the client before the first request so that any peer-sent message arriving during the handshake is dispatched.

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

where 'life0: 'async_trait, StdioTransport: 'async_trait,

Close the transport gracefully. Default is a no-op for transports that close on drop.

fn is_connected(&self) -> bool

Whether the transport is currently connected.