Struct TransportManager 

pub struct TransportManager { /* private fields */ }

OutprocTransportManager - Cross-process transport manager

Responsibilities:

• Manage transport layer for multiple Dests (each Dest maps to one DestTransport)
• Create DestTransport on-demand (lazy initialization)
• Provide unified send/recv interface
• Support custom connection factories
• Prevent duplicate connection creation using Either state machine

Comparison with InprocTransportManager

• OutprocTransportManager: Cross-process, uses WebRTC/WebSocket
• InprocTransportManager: Intra-process, uses mpsc channels, zero serialization

State Machine

None → Connecting(Notify) → Connected(Transport)
        ↓                      ↓
     (multiple waiters)     (ready)

Implementations

impl OutprocTransportManager

pub fn new(local_id: ActrId, conn_factory: Arc<dyn WireBuilder>) -> Self

Create new OutprocTransportManager

Arguments

• local_id: Local Actor ID
• conn_factory: Wire builder, asynchronously creates Wire handle list based on Dest

pub async fn is_closing(&self, dest: &Dest) -> bool

Check if a destination is currently being closed

pub async fn get_or_create_transport( &self, dest: &Dest, ) -> NetworkResult<Arc<DestTransport>>

Get or create DestTransport for specified Dest

Arguments

• dest: Target destination

Returns

• DestTransport for this Dest (Arc-shared)

State Machine

Uses Either to prevent duplicate connections:

1. If Connected → return transport
2. If Connecting → wait for notify, then retry
3. If None → insert Connecting(notify), create connection outside lock

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

Send message to specified Dest

Arguments

• dest: Target destination
• payload_type: Message type
• data: Message data

Example

mgr.send(&dest, PayloadType::RpcSignal, b"hello").await?;

pub async fn close_transport(&self, dest: &Dest) -> NetworkResult<()>

Close DestTransport for specified Dest

Called by OutprocOutGate when connection events indicate cleanup is needed. This triggers the cleanup chain: OutprocTransportManager → DestTransport → WirePool

Arguments

• dest: Target destination

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

Close all DestTransports

pub async fn dest_count(&self) -> usize

Get count of currently managed Dests

pub fn local_id(&self) -> &ActrId

Get local Actor ID

pub async fn list_dests(&self) -> Vec<Dest>

List all connected Dests

pub async fn has_dest(&self, dest: &Dest) -> bool

Check if connection to specified Dest exists

pub fn spawn_health_checker(&self, interval: Duration) -> JoinHandle<()>

Spawn health checker background task with smart reconnect

Periodically checks all DestTransport health status:

• If some connections failed → trigger smart reconnect (reuse working connections)
• If all connections failed → remove entire DestTransport

Arguments

• interval: Health check interval (recommended: 10-30 seconds)

Returns

• JoinHandle for the background task (can be used to cancel)

Example

let mgr = Arc::new(OutprocTransportManager::new(local_id, factory));
let health_check_handle = mgr.spawn_health_checker(Duration::from_secs(10));

Trait Implementations

impl Drop for OutprocTransportManager

fn drop(&mut self)

Executes the destructor for this type.