Enum MessageFromServer 

pub enum MessageFromServer {
    RequestFromServer(RequestFromServer),
    ResultFromServer(ResultFromServer),
    NotificationFromServer(NotificationFromServer),
    Error(RpcError),
}

An enum representing various types of messages that can be sent from an MCP Server. It provides a typed structure for the message payload while skipping internal details like requestId and protocol version, which are used solely by the transport layer and do not need to be exposed to the user.

Variants

RequestFromServer(RequestFromServer)

ResultFromServer(ResultFromServer)

NotificationFromServer(NotificationFromServer)

Error(RpcError)

Trait Implementations

impl Clone for MessageFromServer

fn clone(&self) -> MessageFromServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageFromServer

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MessageFromServer

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<CallToolResult> for MessageFromServer

fn from(value: CallToolResult) -> MessageFromServer

Converts to this type from the input type.

impl From<CancelledNotification> for MessageFromServer

fn from(value: CancelledNotification) -> MessageFromServer

Converts to this type from the input type.

impl From<CompleteResult> for MessageFromServer

fn from(value: CompleteResult) -> MessageFromServer

Converts to this type from the input type.

impl From<CreateMessageRequest> for MessageFromServer

fn from(value: CreateMessageRequest) -> MessageFromServer

Converts to this type from the input type.

impl From<ElicitRequest> for MessageFromServer

fn from(value: ElicitRequest) -> MessageFromServer

Converts to this type from the input type.

impl From<GetPromptResult> for MessageFromServer

fn from(value: GetPromptResult) -> MessageFromServer

Converts to this type from the input type.

impl From<InitializeResult> for MessageFromServer

fn from(value: InitializeResult) -> MessageFromServer

Converts to this type from the input type.

impl From<ListPromptsResult> for MessageFromServer

fn from(value: ListPromptsResult) -> MessageFromServer

Converts to this type from the input type.

impl From<ListResourceTemplatesResult> for MessageFromServer

fn from(value: ListResourceTemplatesResult) -> MessageFromServer

Converts to this type from the input type.

impl From<ListResourcesResult> for MessageFromServer

fn from(value: ListResourcesResult) -> MessageFromServer

Converts to this type from the input type.

impl From<ListRootsRequest> for MessageFromServer

fn from(value: ListRootsRequest) -> MessageFromServer

Converts to this type from the input type.

impl From<ListToolsResult> for MessageFromServer

fn from(value: ListToolsResult) -> MessageFromServer

Converts to this type from the input type.

impl From<LoggingMessageNotification> for MessageFromServer

fn from(value: LoggingMessageNotification) -> MessageFromServer

Converts to this type from the input type.

impl From<MessageFromServer> for MessagesFromServer

fn from(value: MessageFromServer) -> MessagesFromServer

Converts to this type from the input type.

impl From<NotificationFromServer> for MessageFromServer

fn from(value: NotificationFromServer) -> MessageFromServer

Converts to this type from the input type.

impl From<PingRequest> for MessageFromServer

fn from(value: PingRequest) -> MessageFromServer

Converts to this type from the input type.

impl From<ProgressNotification> for MessageFromServer

fn from(value: ProgressNotification) -> MessageFromServer

Converts to this type from the input type.

impl From<PromptListChangedNotification> for MessageFromServer

fn from(value: PromptListChangedNotification) -> MessageFromServer

Converts to this type from the input type.

impl From<ReadResourceResult> for MessageFromServer

fn from(value: ReadResourceResult) -> MessageFromServer

Converts to this type from the input type.

impl From<RequestFromServer> for MessageFromServer

fn from(value: RequestFromServer) -> MessageFromServer

Converts to this type from the input type.

impl From<ResourceListChangedNotification> for MessageFromServer

fn from(value: ResourceListChangedNotification) -> MessageFromServer

Converts to this type from the input type.

impl From<ResourceUpdatedNotification> for MessageFromServer

fn from(value: ResourceUpdatedNotification) -> MessageFromServer

Converts to this type from the input type.

impl From<Result> for MessageFromServer

fn from(value: Result) -> MessageFromServer

Converts to this type from the input type.

impl From<ResultFromServer> for MessageFromServer

fn from(value: ResultFromServer) -> MessageFromServer

Converts to this type from the input type.

impl From<RpcError> for MessageFromServer

fn from(value: RpcError) -> MessageFromServer

Converts to this type from the input type.

impl From<ToolListChangedNotification> for MessageFromServer

fn from(value: ToolListChangedNotification) -> MessageFromServer

Converts to this type from the input type.

impl FromMessage<MessageFromServer> for ServerMessage

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

impl McpMessage for MessageFromServer

fn is_response(&self) -> bool

fn is_request(&self) -> bool

fn is_notification(&self) -> bool

fn is_error(&self) -> bool

fn message_type(&self) -> MessageTypes

impl Serialize for MessageFromServer

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 Transport<ClientMessages, MessageFromServer, ClientMessage, ServerMessages, ServerMessage> for SseTransport<ClientMessage>

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ReceiverStream<ClientMessages>, TransportError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MessageDispatcher<ClientMessage>: McpDispatch<ClientMessages, ServerMessages, ClientMessage, ServerMessage>, SseTransport<ClientMessage>: 'async_trait,

Starts the transport, initializing streams and message dispatcher

Sets up the MCP stream and dispatcher using the provided duplex streams.

Returns

• TransportResult<(Pin<Box<dyn Stream<Item = R> + Send>>, MessageDispatcher<R>, IoStream)>
  • The message stream, dispatcher, and error stream

Errors

• Returns TransportError if streams are already taken or not initialized

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

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

Checks if the transport has been shut down

Returns

• bool - True if the transport is shut down, false otherwise

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

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

Shuts down the transport, terminating tasks and signaling closure

Cancels any running tasks and clears the cancellation source.

Returns

• TransportResult<()> - Ok if shutdown is successful, Err if cancellation fails

fn message_sender( &self, ) -> Arc<RwLock<Option<MessageDispatcher<ClientMessage>>>>

fn error_stream(&self) -> &RwLock<Option<IoStream>>

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

where 'life0: 'async_trait, 'life1: 'async_trait, SseTransport<ClientMessage>: 'async_trait,

fn keep_alive<'life0, 'async_trait>( &'life0 self, interval: Duration, disconnect_tx: Sender<()>, ) -> Pin<Box<dyn Future<Output = Result<JoinHandle<()>, TransportError>> + Send + 'async_trait>>

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

fn pending_request_tx<'life0, 'life1, 'async_trait>( &'life0 self, request_id: &'life1 RequestId, ) -> Pin<Box<dyn Future<Output = Option<Sender<ClientMessage>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, SseTransport<ClientMessage>: 'async_trait,

impl TransportDispatcher<ClientMessages, MessageFromServer, ClientMessage, ServerMessages, ServerMessage> for SseTransport<ClientMessage>

impl TransportDispatcher<ClientMessages, MessageFromServer, ClientMessage, ServerMessages, ServerMessage> for StdioTransport<ClientMessage>