Struct TransportDispatcher 

pub struct TransportDispatcher<T>
where
    T: Transport,
{ /* private fields */ }

Generic dispatcher for any Transport implementation

This provides bidirectional MCP support for any transport that implements the Transport trait. Unlike StdioDispatcher which directly reads/writes stdin/stdout, this uses the Transport trait’s send() and receive() methods.

Usage:

use turbomcp_transport::TcpTransport;
use turbomcp_server::runtime::TransportDispatcher;

let addr = "127.0.0.1:8080".parse().unwrap();
let transport = TcpTransport::new_server(addr);
let dispatcher = TransportDispatcher::new(transport);

Implementations

impl<T> TransportDispatcher<T>

where T: Transport,

pub fn new(transport: T) -> Self

Create a new transport dispatcher

pub fn pending_requests( &self, ) -> Arc<Mutex<HashMap<String, Sender<JsonRpcResponse>>>>

Get access to pending requests for response correlation

pub fn transport(&self) -> Arc<T>

Get access to the transport

Trait Implementations

impl<T> Clone for TransportDispatcher<T>

where T: Transport,

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Debug for TransportDispatcher<T>

where T: Transport,

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

Formats the value using the given formatter.

impl<T> ServerRequestDispatcher for TransportDispatcher<T>

where T: Transport + Send + Sync + 'static,

fn send_elicitation<'life0, 'async_trait>( &'life0 self, request: ElicitRequest, _ctx: RequestContext, ) -> Pin<Box<dyn Future<Output = ServerResult<ElicitResult>> + Send + 'async_trait>>

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

Send an elicitation request to the client

fn send_ping<'life0, 'async_trait>( &'life0 self, _request: PingRequest, _ctx: RequestContext, ) -> Pin<Box<dyn Future<Output = ServerResult<PingResult>> + Send + 'async_trait>>

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

Send a ping request to the client

fn send_create_message<'life0, 'async_trait>( &'life0 self, request: CreateMessageRequest, _ctx: RequestContext, ) -> Pin<Box<dyn Future<Output = ServerResult<CreateMessageResult>> + Send + 'async_trait>>

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

Send a sampling create message request to the client

fn send_list_roots<'life0, 'async_trait>( &'life0 self, _request: ListRootsRequest, _ctx: RequestContext, ) -> Pin<Box<dyn Future<Output = ServerResult<ListRootsResult>> + Send + 'async_trait>>

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

Send a roots list request to the client

fn supports_bidirectional(&self) -> bool

Check if client supports bidirectional communication

fn get_client_capabilities<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ServerResult<Option<Value>>> + Send + 'async_trait>>

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

Get client capabilities