Struct ChannelTransport 

pub struct ChannelTransport { /* private fields */ }

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

Messages are passed through tokio channels: background tasks feed incoming JSON-RPC requests to a JsonRpcService<McpRouter> (one spawned task per request, so calls run concurrently) and pump server notifications into the response stream.

Implementations

impl ChannelTransport

pub fn new(router: McpRouter) -> Self

Create a new channel transport backed by the given router.

Wires an internal notification channel into the router, so notifications emitted during request handling (progress, log messages, list-changed) are delivered to the client. To push notifications from the host process’s own tasks, use with_notifications instead.

Note: this overwrites any notification sender previously set on the router, matching the transport-owns-the-channel behavior of HttpTransport::new.

pub fn with_notifications( router: McpRouter, notification_rx: NotificationReceiver, ) -> Self

Create a channel transport with a caller-owned notification receiver.

Mirrors HttpTransport::with_notifications: the host process keeps the sender (its own clone from notification_channel, or via McpRouter::notification_sender) and pushes ServerNotifications from its own tasks; the transport serializes them into JSON-RPC notification frames and interleaves them into recv.

The router passed here should already carry the matching sender (see the module-level example) so notifications emitted during request handling flow through the same channel.

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 cancel_request<'life0, 'life1, 'async_trait>( &'life0 mut self, request_id: &'life1 RequestId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Cancel one in-flight request.

fn supports_session_recovery(&self) -> bool

Whether this transport supports automatic session recovery.