Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Manages multiple WebSocket connections keyed by SessionId.

Thread-safe, supports concurrent access from multiple Windows. All Firefox windows connect to the same port, messages routed by session.

Example

let pool = ConnectionPool::new().await?;
println!("WebSocket URL: {}", pool.ws_url());

// Wait for a specific session to connect
let ready_data = pool.wait_for_session(session_id).await?;

// Send a request to that session
let response = pool.send(session_id, request).await?;

Implementations

impl ConnectionPool

pub async fn new() -> Result<Arc<Self>>

Creates a new connection pool and starts the accept loop.

Binds to localhost:0 (random available port).

Errors

Returns Error::Io if binding fails.

pub async fn with_port(port: u16) -> Result<Arc<Self>>

Creates a new connection pool bound to a specific port.

Arguments

• port - Port to bind to (0 for random)

Errors

Returns Error::Io if binding fails.

pub async fn with_ip_port(ip: IpAddr, port: u16) -> Result<Arc<Self>>

Creates a new connection pool bound to a specific IP and port.

Arguments

• ip - IP address to bind to
• port - Port to bind to (0 for random)

Errors

Returns Error::Io if binding fails.

impl ConnectionPool

pub fn ws_url(&self) -> String

Returns the WebSocket URL for this pool.

Format: ws://127.0.0.1:{port}

pub fn port(&self) -> u16

Returns the port the pool is bound to.

pub fn connection_count(&self) -> usize

Returns the number of active connections.

pub async fn wait_for_session(&self, session_id: SessionId) -> Result<ReadyData>

Waits for a specific session to connect.

Called by spawn_window after launching Firefox. Returns when Firefox with this sessionId connects and sends READY.

Arguments

• session_id - The session ID to wait for

Errors

• Error::ConnectionTimeout if session doesn’t connect within 30s

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

Sends a request to a specific session.

Arguments

• session_id - Target session
• request - Request to send

Errors

• Error::SessionNotFound if session doesn’t exist
• Error::ConnectionClosed if connection is closed
• Error::RequestTimeout if response not received within timeout

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

Sends a request with custom timeout.

Arguments

• session_id - Target session
• request - Request to send
• timeout - Maximum time to wait for response

Errors

• Error::SessionNotFound if session doesn’t exist
• Error::ConnectionClosed if connection is closed
• Error::RequestTimeout if response not received within timeout

impl ConnectionPool

pub fn set_event_handler(&self, session_id: SessionId, handler: EventHandler)

Sets the event handler for a session.

Arguments

• session_id - Target session
• handler - Event handler callback

pub fn clear_event_handler(&self, session_id: SessionId)

Clears the event handler for a session.

Arguments

• session_id - Target session

impl ConnectionPool

pub fn remove(&self, session_id: SessionId)

Removes a session from the pool.

Called when a Window closes.

Arguments

• session_id - Session to remove

pub async fn shutdown(&self)

Shuts down the pool and all connections.