Struct StdioServerTransport 

pub struct StdioServerTransport { /* private fields */ }

STDIO transport for MCP servers

This transport communicates with an MCP client via STDIO (standard input/output). It reads requests from stdin and writes responses to stdout.

Implementations

impl StdioServerTransport

pub fn new() -> Self

Create a new STDIO server transport

Returns

New STDIO server transport instance

pub fn with_config(config: TransportConfig) -> Self

Create a new STDIO server transport with custom configuration

Arguments

• config - Transport configuration

Returns

New STDIO server transport instance

impl StdioServerTransport

pub async fn handle_request( &mut self, request: JsonRpcRequest, ) -> McpResult<JsonRpcResponse>

Backward compatibility method for tests a default response for testing purposes

Trait Implementations

impl Default for StdioServerTransport

fn default() -> Self

Returns the “default value” for a type.

impl ServerTransport for StdioServerTransport

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

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

Start the server transport and begin listening for connections

fn set_request_handler(&mut self, handler: ServerRequestHandler)

Set the request handler that will process incoming requests

fn set_server_capabilities( &mut self, capabilities: ServerCapabilities, ) -> McpResult<()>

Provide the capabilities used to acknowledge subscription filters.

fn set_task_notifications( &mut self, receiver: Receiver<JsonRpcNotification>, ) -> McpResult<()>

Attach task-status notifications to the transport’s subscription hub.

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 to the client

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

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

Stop the server transport

fn is_running(&self) -> bool

Check if the server is running

fn server_info(&self) -> String

Get server information for debugging

fn set_tool_schemas( &mut self, _schemas: HashMap<String, Value>, ) -> McpResult<()>

Provide registered tool input schemas to transports that mirror and validate MCP routing headers. Other transports may ignore them.