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 add_event_handler(&self, key: String, handler: EventHandler)

Adds an event handler with a key label.

Multiple handlers can be registered simultaneously. When an event arrives, handlers are iterated in order until one returns Some(EventReply).

If a handler with the same key already exists, it is replaced.

pub fn remove_event_handler(&self, key: &str)

Removes an event handler by key.

pub fn clear_all_event_handlers(&self)

Clears all event handlers (for shutdown).

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 Drop for Connection

fn drop(&mut self)

Executes the destructor for this type.