Struct Connection 

pub struct Connection { /* private fields */ }

WebSocket connection to Firefox extension.

Handles request/response correlation and event routing. The connection spawns an internal event loop task.

Thread Safety

Connection is Send + Sync and can be shared across tasks. All operations are non-blocking.

Implementations

impl Connection

pub async fn wait_ready(&self) -> Result<ReadyData>

Waits for the READY handshake message.

Must be called after connection is established. The extension sends READY with nil UUID immediately after connecting.

Errors

• Error::ConnectionTimeout if READY not received within 30s
• Error::ConnectionClosed if connection closes before READY

pub fn set_event_handler(&self, handler: EventHandler)

Sets the event handler callback.

The handler is called for each event received from the extension. Return Some(EventReply) to send a reply back.

pub fn clear_event_handler(&self)

Clears the event handler.

pub async fn send(&self, request: Request) -> Result<Response>

Sends a request and waits for response with default timeout (30s).

Errors

• Error::ConnectionClosed if connection is closed
• Error::RequestTimeout if response not received within timeout
• Error::Protocol if too many pending requests

pub async fn send_with_timeout( &self, request: Request, request_timeout: Duration, ) -> Result<Response>

Sends a request and waits for response with custom timeout.

Arguments

• request - The request to send
• request_timeout - Maximum time to wait for response

Errors

• Error::ConnectionClosed if connection is closed
• Error::RequestTimeout if response not received within timeout
• Error::Protocol if too many pending requests

pub fn pending_count(&self) -> usize

Returns the number of pending requests.

pub fn shutdown(&self)

Shuts down the connection gracefully.

This is called automatically on drop.

Trait Implementations

impl Clone for Connection

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Drop for Connection

fn drop(&mut self)

Executes the destructor for this type.