Struct ChannelTransport 

pub struct ChannelTransport { /* private fields */ }

An in-process ClientTransport that connects directly to an McpRouter.

Messages are passed through tokio channels — the transport spawns a background task that feeds incoming JSON-RPC requests to a JsonRpcService<McpRouter> and returns responses.

Implementations

impl ChannelTransport

pub fn new(router: McpRouter) -> Self

Create a new channel transport backed by the given router.

Spawns a background tokio task that processes requests.

Trait Implementations

impl ClientTransport for ChannelTransport

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

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

Send a raw JSON message to the server.

fn recv<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

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

Receive the next raw JSON message from the server.

fn is_connected(&self) -> bool

Check if the transport is still connected.

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

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

Close the transport gracefully.

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

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

Reset the transport’s session state for re-initialization.

fn supports_session_recovery(&self) -> bool

Whether this transport supports automatic session recovery.