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) -> &str

Returns the WebSocket URL for this pool.

Uses the actual bound IP address instead of hardcoding 127.0.0.1.

Format: ws://{bound_ip}:{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 add_event_handler( &self, session_id: SessionId, key: String, handler: EventHandler, )

Adds an event handler for a session with a key label.

Multiple handlers can be registered for the same session. If a handler with the same key already exists, it is replaced.

Arguments

• session_id - Target session
• key - Unique key for this handler (used for removal)
• handler - Event handler callback

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

Removes an event handler for a session by key.

Arguments

• session_id - Target session
• key - Key of the handler to remove

pub fn clear_all_event_handlers(&self, session_id: SessionId)

Clears all event handlers for a session (for shutdown).

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.