Struct StdioClientTransport 

pub struct StdioClientTransport { /* private fields */ }

STDIO transport for MCP clients

This transport communicates with an MCP server via STDIO (standard input/output). It’s typically used when the server is a separate process.

Implementations

impl StdioClientTransport

pub async fn new<S: AsRef<str>>(command: S, args: Vec<S>) -> McpResult<Self>

Create a new STDIO client transport

Arguments

• command - Command to execute for the MCP server
• args - Arguments to pass to the command

Returns

Result containing the transport or an error

pub async fn new_with_command(command: &str, args: &[String]) -> McpResult<Self>

Create a new STDIO client transport with command string and string args

Arguments

• command - Command to execute for the MCP server
• args - Arguments to pass to the command

Returns

Result containing the transport or an error

pub async fn with_env<S: AsRef<str>>( command: S, args: Vec<S>, env: HashMap<String, String>, ) -> McpResult<Self>

Create a new STDIO client transport with environment variables

Arguments

• command - Command to execute for the MCP server
• args - Arguments to pass to the command
• env - Environment variables to set for the process

Returns

Result containing the transport or an error

pub async fn with_config<S: AsRef<str>>( command: S, args: Vec<S>, config: TransportConfig, ) -> McpResult<Self>

Create a new STDIO client transport with custom configuration

Arguments

• command - Command to execute for the MCP server
• args - Arguments to pass to the command
• config - Transport configuration

Returns

Result containing the transport or an error

pub async fn with_config_and_env<S: AsRef<str>>( command: S, args: Vec<S>, config: TransportConfig, env: Option<HashMap<String, String>>, ) -> McpResult<Self>

Create a new STDIO client transport with custom configuration and environment

Arguments

• command - Command to execute for the MCP server
• args - Arguments to pass to the command
• config - Transport configuration
• env - Optional environment variables to set for the process

Returns

Result containing the transport or an error

Trait Implementations

impl Debug for StdioClientTransport

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

Formats the value using the given formatter.

impl Drop for StdioClientTransport

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Transport for StdioClientTransport

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

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

Send a JSON-RPC request and wait for a response

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

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

Send a JSON-RPC notification (no response expected)

fn receive_notification<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = McpResult<Option<JsonRpcNotification>>> + Send + 'async_trait>>

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

Receive a notification from the server (non-blocking)

fn open_subscription<'life0, 'async_trait>( &'life0 mut self, request: JsonRpcRequest, ) -> Pin<Box<dyn Future<Output = McpResult<ClientSubscription>> + Send + 'async_trait>>

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

Open a modern long-lived subscription stream.

fn cancel_subscription<'life0, 'life1, 'async_trait>( &'life0 mut self, request_id: &'life1 Value, ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>

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

Cancel an open subscription. HTTP implementations close the response stream; STDIO implementations send notifications/cancelled.

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

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

Close the transport connection

fn is_connected(&self) -> bool

Check if the transport is connected

fn connection_info(&self) -> String

Get connection information for debugging

fn handle_incoming_request<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = McpResult<Option<JsonRpcRequest>>> + Send + 'async_trait>>

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

Handle incoming server request (for bidirectional communication)

fn send_response<'life0, 'async_trait>( &'life0 mut self, _response: JsonRpcResponse, ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>

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

Send response to server request (for bidirectional communication)