Struct TokioStdioTransport 

pub struct TokioStdioTransport { /* private fields */ }

Available on crate feature client only.

True async stdio transport using tokio::process.

This implementation:

• Uses tokio::process::Command for async process spawning
• Separate tasks for reading stdout and writing to stdin
• No mutex held during I/O, enabling true concurrent requests
• Pending request map for matching responses to requests

Implementations

impl TokioStdioTransport

pub async fn spawn( command: &str, args: &[String], ) -> Result<Self, McpTransportError>

Spawn a new MCP server process with true async I/O.

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

Spawn with environment variables.

pub async fn send_request( &self, method: &str, params: Option<Value>, timeout_duration: Duration, ) -> Result<Value, McpTransportError>

Send a request and wait for response with timeout.

pub fn is_alive(&self) -> bool

Check if the transport is alive.

pub async fn stop(&self) -> Result<(), McpTransportError>

Stop the transport and kill the process.