Struct ClientSseTransport

pub struct ClientSseTransport { /* private fields */ }

Client-side Server-Sent Events (SSE) transport implementation

Manages SSE connections, HTTP POST requests, and message streaming for client-server communication.

Implementations

impl ClientSseTransport

pub fn new( server_url: &str, options: ClientSseTransportOptions, ) -> Result<ClientSseTransport, TransportError>

Creates a new ClientSseTransport instance

Initializes the transport with the provided server URL and options.

Arguments

• server_url - The URL of the SSE server
• options - Configuration options for the transport

Returns

• TransportResult<Self> - The initialized transport or an error

pub fn validate_message_endpoint( &self, endpoint: String, ) -> Result<String, TransportError>

Validates the message endpoint URL

Ensures the endpoint is either relative to the base URL or matches the base URL’s origin.

Arguments

• endpoint - The endpoint URL to validate

Returns

• TransportResult<String> - The validated endpoint URL or an error

Trait Implementations

impl<R, S> Transport<R, S> for ClientSseTransport

where R: RpcMessage + Clone + Send + Sync + DeserializeOwned + 'static, S: McpMessage + Clone + Send + Sync + Serialize + 'static,

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(Pin<Box<dyn Stream<Item = R> + Send>>, MessageDispatcher<R>, IoStream), TransportError>> + Send + 'async_trait>>

where 'life0: 'async_trait, MessageDispatcher<R>: McpDispatch<R, S>, ClientSseTransport: 'async_trait,

Starts the transport, initializing SSE and POST tasks

Sets up the SSE stream, POST request handler, and message streams for communication.

Returns

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

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

where 'life0: 'async_trait, ClientSseTransport: '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, ClientSseTransport: 'async_trait,

Sends a shutdown signal via the watch channel and kills the subprocess if present.

Returns

A TransportResult indicating success or failure.

Errors

Returns a TransportError if the shutdown signal fails or the process cannot be killed.