Struct InprocTransportManager 

pub struct InprocTransportManager { /* private fields */ }

Inproc Transport Manager - manages intra-process transport (mpsc channels)

Design Philosophy

• Workload ↔ Shell communication bridge (not for arbitrary Actor-to-Actor communication)
• Reliable is mandatory, others are created on-demand
• Dynamic multi-channel management: HashMap<String, Channel>
• Bi-directional sharing: Shell and Workload share the same Manager

Implementations

impl InprocTransportManager

pub fn new() -> Self

Create new instance (only creates Reliable channel, others are lazy-initialized)

InprocTransportManager manages intra-process communication channels between Workload and Shell. It does not need ActorId as all communication is within a single process.

pub async fn create_latency_first_channel( &self, channel_id: String, ) -> Arc<Mutex<Receiver<RpcEnvelope>>>

Create LatencyFirst channel

pub async fn create_media_track_channel( &self, track_id: String, ) -> Arc<Mutex<Receiver<RpcEnvelope>>>

Create MediaTrack channel

pub async fn get_lane( &self, payload_type: PayloadType, identifier: Option<String>, ) -> NetworkResult<DataLane>

Get Lane (with optional channel_id/track_id)

Arguments

• payload_type: PayloadType
• identifier:
  • None for Reliable/Signal
  • Some(channel_id) for LatencyFirst
  • Some(track_id) for MediaTrack

pub async fn send_request( &self, payload_type: PayloadType, identifier: Option<String>, envelope: RpcEnvelope, ) -> NetworkResult<Bytes>

Send request (with response waiting)

pub async fn send_message( &self, payload_type: PayloadType, identifier: Option<String>, envelope: RpcEnvelope, ) -> NetworkResult<()>

Send one-way message

pub async fn recv(&self) -> Option<RpcEnvelope>

Receive one message (select first available from all channels)

Returns

• Some(envelope): received message (response matching already handled)
• None: all channels closed

pub async fn complete_response( &self, request_id: &str, response_bytes: Bytes, ) -> NetworkResult<()>

Complete a pending request with response payload

Arguments

• request_id: The request ID to complete
• response_bytes: Response payload

Returns

• Ok(()): Successfully sent response to waiting sender
• Err(NetworkError): No pending request found with this ID

pub async fn complete_error( &self, request_id: &str, error: ProtocolError, ) -> NetworkResult<()>

Complete a pending request with an error

Returns

• Ok(()): Successfully sent error to waiting sender
• Err(NetworkError): No pending request found with this ID

Trait Implementations

impl Default for InprocTransportManager

fn default() -> Self

Returns the “default value” for a type.