Struct WsRpc 

pub struct WsRpc<P: Protocol> { /* private fields */ }

Shared JSON-RPC-over-WebSocket transport. Owns the socket, the reader and writer tasks (and their JoinHandles), the pending-request correlation map, the id counter, and the event broadcast channel.

Implementations

impl<P: Protocol> WsRpc<P>

pub async fn connect(ws_url: &str, label: &str) -> Result<Self>

Connect by full WebSocket URL (ws:// or wss://) and spawn the reader and writer tasks. label is used only in the connect-timeout error message (e.g. "CDP" / "BiDi").

pub async fn request( &self, method: &str, params: Value, session_id: Option<&str>, ) -> Result<Value, RequestError<P::ProtoError>>

Send a request and await its correlated reply, bounded by REQUEST_TIMEOUT. On writer-channel failure the pending entry is removed before returning (no leak); on timeout it is likewise removed. A protocol error reply comes back as RequestError::Protocol; transport faults (writer closed / channel dropped / serialization) as RequestError::Transport; a no-reply timeout as RequestError::Timeout.

Callers map these through their own classifier so the protocol-specific typing stays in crate::cdp / crate::bidi.

pub fn subscribe(&self) -> Receiver<P::Event>

Subscribe to the broadcast event stream. Drop the receiver to unsubscribe.

pub async fn close(self)

Gracefully shut down: close the writer (flushing the socket), then abort and join the reader. Mirrors the previous CdpClient::close. Taking the handles here leaves Drop with nothing to abort.

Trait Implementations

impl<P: Protocol> Drop for WsRpc<P>

fn drop(&mut self)

Ensure dropping the transport (e.g. a cached Arc<CdpClient> cleared by switch_browser) never leaks the parked reader/writer tasks, even when the graceful close() was not called.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.