Struct WirePool 

pub struct WirePool { /* private fields */ }

WirePool - Wire connection pool manager

Responsibilities

• Saturated concurrent connections (simultaneously attempt WebRTC + WebSocket)
• Automatic retry with exponential backoff
• Broadcast connection status (via watch channel, zero-polling)
• Keep all successful connections (no priority-based replacement)

Design Highlights

• Event-driven: Use watch channels to notify status changes
• Zero-polling: Callers use await ready_rx.changed() to wait for connection readiness
• Array optimization: Use fixed-size array instead of HashMap

Implementations

impl WirePool

pub fn new(retry_config: RetryConfig) -> Self

Create new wire connection pool

pub fn add_connection(&self, connection: WireHandle)

Add connection and start connection task in background

Non-blocking, returns immediately and attempts connection concurrently in background

Behavior

• Unconditionally starts: Always starts connection attempt, even if a connection already exists
• Use add_connection_smart() if you want to skip already-ready connections

pub async fn add_connection_smart(&self, connection: WireHandle)

Add connection smartly - skip if already Ready or Connecting

Behavior

• Ready: Skip (reuse existing connection)
• Connecting: Skip (avoid duplicate retry)
• None/Failed: Start connection attempt

Use Case

Perfect for reconnection scenarios where you want to retry failed connections without disrupting working ones.

pub fn watch_ready(&self) -> Receiver<HashSet<ConnType>>

Watch for connection status changes

pub fn get_ready(&self) -> HashSet<ConnType>

Get current ready connection set

pub async fn get_connection(&self, conn_type: ConnType) -> Option<WireHandle>

Get connection of specified type

pub async fn wait_for_any(&self) -> NetworkResult<()>

Wait for any connection to become ready

pub async fn mark_connection_closed(&self, conn_type: ConnType)

Mark a connection as closed/failed

Called by upper layers (DestTransport) when closing connections. This replaces the per-connection event listener pattern.

pub async fn close_all(&self)

Close all connections in the pool

Called by DestTransport.close() to clean up all connections. This also terminates all background connection tasks.

pub fn is_closed(&self) -> bool

Check if pool is closed