Struct CdpConnection 

pub struct CdpConnection { /* private fields */ }

The single shared CDP connection over one WebSocket.

Cheap to share via Arc<CdpConnection>. A background dispatch task runs until the socket closes; when it does, all pending callbacks resolve to Error::ChannelClosed.

Implementations

impl CdpConnection

pub async fn connect( ws_url: &str, headers: Option<HashMap<String, String>>, ) -> Result<(Arc<Self>, Receiver<CdpEvent>)>

Connect to a CDP WebSocket endpoint and start the dispatch task.

Returns the shared connection plus a receiver for browser-level events (session_id == None).

pub async fn send_command( self: &Arc<Self>, session_id: Option<&str>, method: &str, params: Value, ) -> Result<Value>

Send a CDP command and await its response (no timeout — wrap at a higher layer if needed). session_id is None for browser-level.

pub fn subscribe(&self, session_id: Option<String>) -> Receiver<CdpEvent>

Subscribe to events for a session. None = browser-level. New subscribers only receive events emitted after this call — subscribe before issuing the command whose events you want to observe.

pub async fn close(&self) -> Result<()>

Best-effort graceful close of the underlying socket.