Struct InboundPacketDispatcher 

pub struct InboundPacketDispatcher { /* private fields */ }

InboundPacketDispatcher - Inbound packet dispatcher

Design Principles

• Single Responsibility: Only responsible for routing inbound packets
• Zero-copy: Pass bytes directly, no deserialization until needed
• Thread-safe: All components wrapped in Arc
• Response matching: Wake up pending_requests via OutprocOutGate

Note on MediaTrack

MediaTrack (PayloadType::MediaRtp) is NOT handled here because:

• MediaTrack uses WebRTC native RTP channels, not DataChannel
• Media frames are delivered directly via RTCTrackRemote callbacks
• No protobuf serialization involved
• MediaFrameRegistry is registered at WebRTC PeerConnection level

Implementations

impl InboundPacketDispatcher

pub fn new( mailbox: Arc<dyn Mailbox>, data_stream_registry: Arc<DataStreamRegistry>, outproc_out_gate: Option<Arc<OutprocOutGate>>, ) -> Self

Create new InboundPacketDispatcher

Arguments

• mailbox: Mailbox instance
• data_stream_registry: DataStream registry
• outproc_out_gate: OutprocOutGate instance (optional, for RPC response matching)

pub async fn dispatch(&self, packet: InboundPacket)

Dispatch inbound packet

Core Logic

1. Check if this is an RPC response (has request_id)
2. If response, wake up OutprocOutGate.pending_requests
3. If request, route to appropriate handler by PayloadType

Arguments

• packet: Inbound packet

pub async fn handle_response(&self, envelope: RpcEnvelope) -> bool

Handle RPC response (wake up pending_requests)

Design

• Only handle if outproc_out_gate exists
• Decode RpcEnvelope, extract request_id
• Call OutprocOutGate::handle_response to wake up waiting request

Returns

• true: Successfully matched and woke up
• false: No matching pending request found