Struct WebSocketTransportConfig 

pub struct WebSocketTransportConfig {
    pub request_timeout: Duration,
    pub extra_headers: HashMap<String, String>,
    pub connect_timeout: Duration,
    pub max_message_size: usize,
}

Configuration for WebSocketTransport::connect_with_config.

Fields

request_timeout: Duration

Timeout for unary responses and for the first frame of a stream. Default: 30 seconds.

extra_headers: HashMap<String, String>

Extra HTTP headers for the WebSocket upgrade request (e.g. an Authorization header produced by an AuthInterceptor).

connect_timeout: Duration

How long the connect may take: TCP, TLS, and the HTTP upgrade handshake, together. Default: 10 seconds.

Nothing bounded this. connect_async_with_config was awaited bare, and no OS timeout covers an upgrade that is answered late or never — a server that accepts the TCP connection and then goes silent held the caller forever. Measured against such a server: still pending at 3 seconds, with no deadline to reach.

Every sibling transport already bounded this — JSON-RPC and REST through ClientConfig::connection_timeout, gRPC through GrpcTransportConfig::connect_timeout — and this default matches theirs. ClientConfig::connection_timeout cannot reach here: this transport is built directly and handed to with_custom_transport, so it never sees a ClientConfig.

max_message_size: usize

Maximum size of an incoming WebSocket message, in bytes, enforced at the protocol level during the read. Default: 32 MiB, replacing tungstenite’s 64 MiB default.

That default is DEFAULT_MAX_RESPONSE_SIZE, the same constant the HTTP and gRPC transports start from — the same value, not the same setting. This transport is reached through with_custom_transport, so it never sees a ClientConfig and max_response_size does not reach it. The two agree until somebody changes one, and the person who tightens a limit is the person who decided the default was wrong for them. Set the bound here.

Implementations

impl WebSocketTransportConfig

pub const fn with_request_timeout(self, timeout: Duration) -> Self

Sets the request timeout.

pub const fn with_connect_timeout(self, timeout: Duration) -> Self

Sets how long the connect may take, handshake included.

pub fn with_extra_headers(self, headers: HashMap<String, String>) -> Self

Sets extra HTTP headers for the upgrade request.

pub const fn with_max_message_size(self, max_bytes: usize) -> Self

Sets the maximum incoming message size in bytes.

Trait Implementations

impl Clone for WebSocketTransportConfig

fn clone(&self) -> WebSocketTransportConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WebSocketTransportConfig

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

Formats the value using the given formatter.

impl Default for WebSocketTransportConfig

fn default() -> Self

Returns the “default value” for a type.