Struct CDPClient 

pub struct CDPClient { /* private fields */ }

Core CDP client that manages WebSocket connection and message routing

Implementations

impl CDPClient

pub fn new(ws_url: String) -> Self

Create a new CDP client

pub async fn set_sink(&self, sink: WebSocketSink)

Set the WebSocket sink (called from Connection)

pub fn next_id(&self) -> u32

Generate the next message ID

pub async fn connect( &self, ) -> Result<WebSocketStream<MaybeTlsStream<TcpStream>>>

Connect to the Chrome DevTools Protocol WebSocket

pub async fn send_raw(&self, msg: String) -> Result<()>

Send raw message through WebSocket

pub fn subscribe_events(&self) -> Receiver<CDPMessage>

Subscribe to all CDP events (unfiltered broadcast receiver).

Callers are responsible for filtering by msg.method and msg.session_id as needed.

IMPORTANT: Subscribe before sending the CDP command that triggers the event to avoid the race where Chrome replies before the receiver is registered.

pub async fn send_command( &self, method: String, params: Option<Value>, ) -> Result<Value>

Send a command and wait for response with timeout.

The response handler is registered before the message is sent so that fast Chrome replies are never dropped.

pub async fn send_command_with_session( &self, session_id: &str, method: String, params: Option<Value>, ) -> Result<Value>

Send a command to a specific page session.

The response handler is registered before the message is sent.

pub async fn register_response_handler(&self, id: u32, tx: Sender<Value>)

Register a pending response handler

pub async fn handle_message(&self, msg: CDPMessage) -> Result<()>

Handle an incoming CDP message — called by Connection