Struct MessageHandler

pub struct MessageHandler<T: Transport + 'static> { /* private fields */ }

Implementations

impl<T: Transport + 'static> MessageHandler<T>

pub fn new( transport: Arc<T>, pending_requests: Arc<Mutex<HashMap<u64, Sender<JsonRpcResponse>>>>, sampling_handler: Option<Arc<Box<dyn SamplingHandler + Send>>>, notification_handler: Option<Arc<Box<dyn NotificationHandler + Send>>>, ) -> Self

pub fn handle_message(&self, message: JsonRpcMessage) -> Result<(), McpError>

pub fn handle_request(&self, request: JsonRpcRequest) -> Result<(), McpError>

pub fn handle_sampling_request( &self, handler: &Arc<Box<dyn SamplingHandler + Send>>, request: &JsonRpcRequest, ) -> Result<(), McpError>

pub fn handle_response(&self, response: JsonRpcResponse) -> Result<(), McpError>

pub fn handle_notification( &self, notification: JsonRpcNotification, ) -> Result<(), McpError>