Struct RtcEgress 

pub(super) struct RtcEgress {
    udp: UdpEgress,
}

Network output for one RTC worker.

UDP and future TCP adapters share this dispatch boundary without moving session state or protocol-specific send mechanics into the worker.

Fields

udp: UdpEgress

Implementations

impl RtcEgress

pub fn new( socket: RtcUdpSocket, candidate_addr: SocketAddr, rtc_metrics: Arc<RtcMetricsRecorder>, ) -> Self

pub async fn flush(&mut self, transmits: &mut Vec<Transmit>)

Dispatches staged instructions and retains the vector capacity.

Non-UDP instructions are rejected before any UDP socket wait. The remaining UDP instructions retain their relative order across windows. UDP sources must match the announced candidate, including its port. Rejected instructions and socket failures do not suppress later output. Payloads remain owned until socket I/O completes. No output queue survives a completed flush.

Failure reporting

Rejections log reason = "unsupported_protocol" or reason = "source_mismatch". Send failures increment worker transport I/O counters and emit sampled warnings with category, suppressed and destination. Warnings include raw_os_error when available. Unexpected UDP send lengths use the same reporting without retrying potentially accepted bytes.

The worker awaits the entire flush before applying its next input. Once draining begins, cancellation discards unsubmitted UDP output.