Struct DestTransport 

pub struct DestTransport { /* private fields */ }

DestTransport - Transport layer manager for a single destination

Core responsibilities:

• Manage all connections to a specific Dest (WebSocket + WebRTC)
• Concurrently establish connections in background (saturated connection pattern)
• Event-driven wait for connection status
• Cache Lanes within WireHandle
• WirePool handles priority selection

Implementations

impl DestTransport

pub async fn new( dest: Dest, connections: Vec<WireHandle>, ) -> NetworkResult<Self>

Create new DestTransport

Arguments

• dest: destination
• connections: list of pre-built connections (WebSocket/WebRTC)

pub async fn send( &self, payload_type: PayloadType, data: &[u8], ) -> NetworkResult<()>

Send message

Core design: event-driven waiting

• If connection available, send immediately
• If not, wait for connection status change (via watch channel)
• WirePool already handles priority, only need to try DataLane Types in order

pub async fn retry_failed_connections( &self, dest: &Dest, wire_builder: &dyn WireBuilder, ) -> NetworkResult<()>

Retry failed connections (smart reconnect)

Behavior

• Calls WireBuilder to create new connections
• Uses add_connection_smart() to skip already-working connections
• Perfect for reconnection after detecting connection failures

Arguments

• dest: destination (used by WireBuilder)
• wire_builder: factory to create new WireHandles

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

Close DestTransport and release all connection resources

pub async fn has_healthy_connection(&self) -> bool

Check if any connection is still healthy

Used by health checker to detect failed connections

Returns

• true: at least one connection is healthy (connected)
• false: all connections are unhealthy or no connections exist

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

Subscribe to ready-set changes (used for manager-side cleanup).