Enum ClientMessage

pub enum ClientMessage {
    Request(ClientJsonrpcRequest),
    Notification(ClientJsonrpcNotification),
    Response(ClientJsonrpcResponse),
    Error(JsonrpcError),
}

“Similar to JsonrpcMessage, but with the variants restricted to client-side messages.” ClientMessage represents a message sent by an MCP Client and received by an MCP Server.

Variants

Request(ClientJsonrpcRequest)

Notification(ClientJsonrpcNotification)

Response(ClientJsonrpcResponse)

Error(JsonrpcError)

Implementations

impl ClientMessage

pub fn as_response(self) -> Result<ClientJsonrpcResponse, RpcError>

Converts the current message into a ClientJsonrpcResponse if it’s of the correct type.

This function checks if the current message is of type Response. If so, it returns the ClientJsonrpcResponse wrapped in a Result::Ok. If the message is not a Response, it returns an error with a descriptive message indicating the mismatch in expected message types.

Returns

• Ok(ClientJsonrpcResponse) if the message is a valid Response.
• Err(RpcError) if the message type is invalid

pub fn as_request(self) -> Result<ClientJsonrpcRequest, RpcError>

Converts the current message into a ClientJsonrpcRequest if it’s of the correct type.

This function checks if the current message is of type Request. If so, it returns the ClientJsonrpcRequest wrapped in a Result::Ok. If the message is not a Request, it returns an error with a descriptive message indicating the mismatch in expected message types.

Returns

• Ok(ClientJsonrpcRequest) if the message is a valid Request.
• Err(RpcError) if the message type is invalid

pub fn as_notification(self) -> Result<ClientJsonrpcNotification, RpcError>

Converts the current message into a ClientJsonrpcNotification if it’s of the correct type.

This function checks if the current message is of type Notification. If so, it returns the ClientJsonrpcNotification wrapped in a Result::Ok. If the message is not a Notification, it returns an error with a descriptive message indicating the mismatch in expected message types.

Returns

• Ok(ClientJsonrpcNotification) if the message is a valid Notification.
• Err(RpcError) if the message type is invalid

pub fn as_error(self) -> Result<JsonrpcError, RpcError>

Converts the current message into a JsonrpcError if it’s of the correct type.

This function checks if the current message is of type Error. If so, it returns the JsonrpcError wrapped in a Result::Ok. If the message is not a Error, it returns an error with a descriptive message indicating the mismatch in expected message types.

Returns

• Ok(JsonrpcError) if the message is a valid Error.
• Err(RpcError) if the message type is invalid

Trait Implementations

impl Clone for ClientMessage

fn clone(&self) -> ClientMessage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ClientMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ClientMessage

fn deserialize<__D>( __deserializer: __D, ) -> Result<ClientMessage, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for ClientMessage

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

Formats the value using the given formatter.

impl FromMessage<CallToolRequest> for ClientMessage

fn from_message( message: CallToolRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<CancelledNotification> for ClientMessage

fn from_message( message: CancelledNotification, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<CompleteRequest> for ClientMessage

fn from_message( message: CompleteRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<CreateMessageResult> for ClientMessage

fn from_message( message: CreateMessageResult, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<GetPromptRequest> for ClientMessage

fn from_message( message: GetPromptRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<InitializeRequest> for ClientMessage

fn from_message( message: InitializeRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<InitializedNotification> for ClientMessage

fn from_message( message: InitializedNotification, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<ListPromptsRequest> for ClientMessage

fn from_message( message: ListPromptsRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<ListResourceTemplatesRequest> for ClientMessage

fn from_message( message: ListResourceTemplatesRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<ListResourcesRequest> for ClientMessage

fn from_message( message: ListResourcesRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<ListRootsResult> for ClientMessage

fn from_message( message: ListRootsResult, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<ListToolsRequest> for ClientMessage

fn from_message( message: ListToolsRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<MessageFromClient> for ClientMessage

fn from_message( message: MessageFromClient, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<PingRequest> for ClientMessage

fn from_message( message: PingRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<ProgressNotification> for ClientMessage

fn from_message( message: ProgressNotification, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<ReadResourceRequest> for ClientMessage

fn from_message( message: ReadResourceRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<Result> for ClientMessage

fn from_message( message: Result, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<RootsListChangedNotification> for ClientMessage

fn from_message( message: RootsListChangedNotification, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<SetLevelRequest> for ClientMessage

fn from_message( message: SetLevelRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<SubscribeRequest> for ClientMessage

fn from_message( message: SubscribeRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromMessage<UnsubscribeRequest> for ClientMessage

fn from_message( message: UnsubscribeRequest, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl FromStr for ClientMessage

type Err = RpcError

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<ClientMessage, <ClientMessage as FromStr>::Err>

Parses a string s to return a value of this type.

impl McpDispatch<ClientMessage, MessageFromServer> for MessageDispatcher<ClientMessage>

fn send<'life0, 'async_trait>( &'life0 self, message: MessageFromServer, request_id: Option<RequestId>, request_timeout: Option<Duration>, ) -> Pin<Box<dyn Future<Output = Result<Option<ClientMessage>, TransportError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MessageDispatcher<ClientMessage>: 'async_trait,

Sends a message from the server to the client and awaits a response if applicable.

Serializes the MessageFromServer to JSON, writes it to the transport, and waits for a ClientMessage response if the message is a request. Notifications and responses return Ok(None).

Arguments

• message - The server message to send.
• request_id - An optional request ID (used for responses/errors, None for requests).

Returns

A TransportResult containing Some(ClientMessage) for requests with a response, or None for notifications/responses, or an error if the operation fails.

Errors

Returns a TransportError if serialization, writing, or timeout occurs.

impl McpMessage for ClientMessage

fn message_type(&self) -> MessageTypes

Determines the type of the message and returns the corresponding MessageTypes variant.

fn is_response(&self) -> bool

fn is_request(&self) -> bool

fn is_notification(&self) -> bool

fn is_error(&self) -> bool

impl RpcMessage for ClientMessage

fn request_id(&self) -> Option<&RequestId>

fn jsonrpc(&self) -> &str

impl Serialize for ClientMessage

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ToMessage<ClientMessage> for CallToolRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for CancelledNotification

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for CompleteRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for CreateMessageResult

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for GetPromptRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for InitializeRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for InitializedNotification

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for ListPromptsRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for ListResourceTemplatesRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for ListResourcesRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for ListRootsResult

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for ListToolsRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for PingRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for ProgressNotification

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for ReadResourceRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for Result

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for RootsListChangedNotification

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for SetLevelRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for SubscribeRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>

impl ToMessage<ClientMessage> for UnsubscribeRequest

fn to_message( self, request_id: Option<RequestId>, ) -> Result<ClientMessage, RpcError>