Struct StdioClientTransport 

pub struct StdioClientTransport<R, W>
where
    R: AsyncRead + Unpin + Send,
    W: AsyncWrite + Unpin + Send,
{ /* private fields */ }

Standard I/O transport for MCP client

Communicates with an MCP server via stdin/stdout streams. Typically used with child process spawning.

Implementations

impl<R, W> StdioClientTransport<R, W>

where R: AsyncRead + Unpin + Send, W: AsyncWrite + Unpin + Send,

pub fn new(reader: R, writer: W) -> Self

Create a new stdio transport from read and write streams

Arguments

• reader - The input stream (typically child process stdout)
• writer - The output stream (typically child process stdin)

Trait Implementations

impl<R, W> ClientTransport for StdioClientTransport<R, W>

where R: AsyncRead + Unpin + Send + 'static, W: AsyncWrite + Unpin + Send + 'static,

fn send<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 Request, ) -> Pin<Box<dyn Future<Output = ClientResult<()>> + Send + 'async_trait>>

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

Send a JSON-RPC request to the server

fn recv<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ClientResult<JsonRpcMessage>> + Send + 'async_trait>>

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

Receive the next message from the server

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

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

Close the transport