Struct StdioTransport 

pub struct StdioTransport { /* private fields */ }

Standard I/O transport implementation

Interior Mutability Architecture

Following research-backed 2025 Rust async best practices:

• state: std::sync::Mutex (short-lived locks, never held across .await)
• config: std::sync::Mutex (infrequent updates, short-lived locks)
• metrics: AtomicMetrics (lock-free counters, 10-100x faster than Mutex)
• I/O streams: tokio::sync::Mutex (held across .await, necessary for async I/O)

Implementations

impl StdioTransport

pub fn new() -> StdioTransport

Create a new stdio transport

pub fn with_config(config: TransportConfig) -> StdioTransport

Create a stdio transport with custom configuration

pub fn with_event_emitter( event_emitter: TransportEventEmitter, ) -> StdioTransport

Create a stdio transport with event emitter

Trait Implementations

impl Debug for StdioTransport

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

Formats the value using the given formatter.

impl Default for StdioTransport

fn default() -> StdioTransport

Returns the “default value” for a type.

impl Transport for StdioTransport

fn transport_type(&self) -> TransportType

Returns the type of this transport.

fn capabilities(&self) -> &TransportCapabilities

Returns the capabilities of this transport.

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

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

Returns the current state of the transport.

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

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

Establishes a connection to the remote endpoint.

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

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

Closes the connection to the remote endpoint.

fn send<'life0, 'async_trait>( &'life0 self, message: TransportMessage, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

Sends a single message over the transport.

fn receive<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<TransportMessage>, TransportError>> + Send + 'async_trait>>

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

Receives a single message from the transport in a non-blocking way.

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

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

Returns a snapshot of the transport’s current performance metrics.

fn endpoint(&self) -> Option<String>

Returns the endpoint address or identifier for this transport, if applicable.

fn configure<'life0, 'async_trait>( &'life0 self, config: TransportConfig, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

Applies a new configuration to the transport.

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

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

Returns true if the transport is currently in the Connected state.