Struct WebSocketClientTransport

pub struct WebSocketClientTransport { /* private fields */ }

WebSocket transport for MCP clients

This transport communicates with an MCP server via WebSocket connections, providing bidirectional real-time communication for both requests and notifications.

Implementations

impl WebSocketClientTransport

pub async fn new<S: AsRef<str>>(url: S) -> McpResult<Self>

Create a new WebSocket client transport

Arguments

• url - WebSocket URL to connect to (e.g., “ws://localhost:8080/mcp”)

Returns

Result containing the transport or an error

pub async fn with_config<S: AsRef<str>>( url: S, config: TransportConfig, ) -> McpResult<Self>

Create a new WebSocket client transport with custom configuration

Arguments

• url - WebSocket URL to connect to
• config - Transport configuration

Returns

Result containing the transport or an error

Trait Implementations

impl Transport for WebSocketClientTransport

fn send_request<'life0, 'async_trait>( &'life0 mut self, request: JsonRpcRequest, ) -> Pin<Box<dyn Future<Output = McpResult<JsonRpcResponse>> + Send + 'async_trait>>

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

Send a JSON-RPC request and wait for a response

fn send_notification<'life0, 'async_trait>( &'life0 mut self, notification: JsonRpcNotification, ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>

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

Send a JSON-RPC notification (no response expected)

fn receive_notification<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = McpResult<Option<JsonRpcNotification>>> + Send + 'async_trait>>

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

Receive a notification from the server (non-blocking)

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

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

Close the transport connection

fn is_connected(&self) -> bool

Check if the transport is connected

fn connection_info(&self) -> String

Get connection information for debugging