Struct Connection 

pub struct Connection { /* private fields */ }

One CDP connection.

Implementations

impl Connection

pub async fn connect_endpoint( endpoint: &Endpoint, token: Option<&str>, ) -> Result<Self, Error>

Open a CDP connection from a parsed endpoint.

pub async fn connect( endpoint_ws_url: &str, token: Option<&str>, ) -> Result<Self, Error>

Open a CDP connection to ws://endpoint/cdp (or wss://), attaching the optional bearer token via the ?token_secret= query parameter (the _secret suffix lets AFDATA redaction scrub it).

pub fn subscribe(&self) -> Receiver<CdpEvent>

Subscribe to events for the lifetime of this connection.

pub async fn send<P: Serialize>( &self, method: &str, params: &P, session_id: Option<&str>, ) -> Result<Value, Error>

Send a CDP command and await the result. session_id is Some when the call is scoped to a flattened session (after Target.attachToTarget).

pub async fn send_timeout<P: Serialize>( &self, method: &str, params: &P, session_id: Option<&str>, timeout: Duration, ) -> Result<Value, Error>

Send a CDP command and fail with cdp_timeout if the browser does not answer within timeout. Unlike wrapping Self::send externally, this removes the pending reply slot on timeout.

pub async fn wait_event<F>( &self, timeout: Duration, predicate: F, ) -> Result<CdpEvent, Error>

where F: FnMut(&CdpEvent) -> bool,

Wait for a CDP event matching predicate (true = matches). Returns cdp_timeout if timeout elapses first.

pub fn close(&self)

Trait Implementations

impl Drop for Connection

fn drop(&mut self)

Executes the destructor for this type.

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.