Struct WebSocketTransport 

pub struct WebSocketTransport { /* private fields */ }

WebSocket transport: JSON-RPC 2.0 over a persistent WebSocket connection.

Create via WebSocketTransport::connect and pass to crate::ClientBuilder::with_custom_transport.

FIX(C2): Uses a dedicated reader task with message routing instead of a shared Mutex on the reader half. This prevents deadlocks when streaming responses are received concurrently with unary requests.

Implementations

impl WebSocketTransport

pub async fn connect(endpoint: impl Into<String>) -> ClientResult<Self>

Connects to the agent’s WebSocket endpoint.

The endpoint should use the ws:// or wss:// scheme.

Errors

Returns ClientError::Transport if the WebSocket handshake fails.

pub async fn connect_with_timeout( endpoint: impl Into<String>, request_timeout: Duration, ) -> ClientResult<Self>

Connects with a custom request timeout.

Errors

Returns ClientError::Transport if the WebSocket handshake fails.

pub async fn connect_with_options( endpoint: impl Into<String>, request_timeout: Duration, extra_headers: &HashMap<String, String>, ) -> ClientResult<Self>

Connects with a custom request timeout and extra HTTP headers for the initial WebSocket upgrade request.

FIX(C3): Extra headers (e.g. from AuthInterceptor) are applied to the HTTP upgrade request that establishes the WebSocket connection via the tungstenite IntoClientRequest trait.

Errors

Returns ClientError::Transport if the WebSocket handshake fails.

pub fn endpoint(&self) -> &str

Returns the endpoint URL this transport is connected to.

Trait Implementations

impl Debug for WebSocketTransport

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

Formats the value using the given formatter.

impl Transport for WebSocketTransport

fn send_request<'a>( &'a self, method: &'a str, params: Value, extra_headers: &'a HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = ClientResult<Value>> + Send + 'a>>

Sends a non-streaming JSON-RPC or REST request.

fn send_streaming_request<'a>( &'a self, method: &'a str, params: Value, extra_headers: &'a HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = ClientResult<EventStream>> + Send + 'a>>

Sends a streaming request and returns an EventStream.