Struct ResponsesWebsocketClient 

pub struct ResponsesWebsocketClient { /* private fields */ }

Client for connecting to the Responses WebSocket endpoint for one provider.

Implementations

impl ResponsesWebsocketClient

pub fn new(provider: Provider, auth: SharedAuthProvider) -> Self

Creates a Responses WebSocket client for an already-resolved provider and auth source.

pub async fn connect( &self, http_client_factory: &HttpClientFactory, extra_headers: HeaderMap, default_headers: HeaderMap, turn_state: Option<Arc<OnceLock<String>>>, telemetry: Option<Arc<dyn WebsocketTelemetry>>, ) -> Result<ResponsesWebsocketConnection, ApiError>

pub async fn probe_handshake( &self, http_client_factory: &HttpClientFactory, extra_headers: HeaderMap, default_headers: HeaderMap, immediate_close_timeout: Duration, ) -> Result<ResponsesWebsocketProbe, ApiError>

Opens a WebSocket connection long enough to validate the upgrade response.

The probe uses the same URL construction, headers, authentication, TLS, and custom-CA path as a real Responses WebSocket connection, but it does not send a request frame. After the HTTP 101 upgrade succeeds, it waits briefly for an immediate server close frame so diagnostics can distinguish a usable connection from a policy rejection that closes right away.