Struct WebSocketClientTransport 

pub struct WebSocketClientTransport { /* private fields */ }

A WebSocket client transport for MCP backend connections.

Connects to a WebSocket endpoint and exchanges JSON-RPC messages as text frames. Supports ws:// and wss:// (TLS) URLs.

Implementations

impl WebSocketClientTransport

pub async fn connect(url: &str) -> Result<Self>

Connect to a WebSocket endpoint.

Errors

Returns an error if the WebSocket handshake fails or the URL is invalid.

pub async fn connect_with_bearer_token(url: &str, token: &str) -> Result<Self>

Connect to a WebSocket endpoint with a bearer token for authentication.

The token is sent in the Authorization header during the handshake.

Trait Implementations

impl ClientTransport for WebSocketClientTransport

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

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

Send a raw JSON message to the server.

fn recv<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

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

Receive the next raw JSON message from the server.

fn is_connected(&self) -> bool

Check if the transport is still connected.

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

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

Close the transport gracefully.