Struct StreamMuxReceiver 

pub struct StreamMuxReceiver { /* private fields */ }

Receiver side of the stream multiplexer.

Implementations

impl StreamMuxReceiver

pub fn bind<A: ToSocketAddrs>(local: A, symbol_len: usize) -> Result<Self>

Bind a receiver over symbol_len-byte symbols.

pub fn local_addr(&self) -> Result<SocketAddr>

The bound local address.

pub fn fec_recovered(&self) -> u64

Total symbols recovered by FEC (no retransmit) across all streams.

pub fn naks_sent(&self) -> u64

NAK frames sent across all streams.

pub fn stream_protection(&self, stream_id: u32) -> Option<Protection>

The FEC policy a stream is being received with, if it exists.

pub fn expect_stream(&mut self, stream_id: u32, protection: Protection)

Declare a stream’s FEC policy on the receive side (so a Protected stream runs an RLC decoder). A stream the sender opens before this is seen defaults to Bulk.

pub fn with_stream_loss(self, stream_id: u32, pct: u32, seed: u64) -> Self

Inject seeded diagnostic loss on a stream (percent of arriving symbols), to exercise recovery on loopback.

pub fn poll(&mut self) -> Result<Vec<StreamData>>

Receive any pending datagrams, run FEC recovery, and return the bytes that became deliverable on each stream (each stream independently in order).