Struct StreamMuxSender 

pub struct StreamMuxSender { /* private fields */ }

Sender side of the stream multiplexer.

Implementations

impl StreamMuxSender

pub fn bind<A: ToSocketAddrs>( local: A, peer: SocketAddr, symbol_len: usize, conn_window: u32, per_stream_window: u32, ) -> Result<Self>

Bind a local socket and connect to peer, coding over symbol_len-byte symbols. conn_window caps total outstanding symbols; per_stream_window caps each stream’s share.

pub fn conn_id(&self) -> u64

The connection id stamped into every frame.

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

The FEC policy a stream was opened with, if it exists.

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

The sender’s local address.

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

Open a stream with the given FEC policy. Re-opening keeps the existing stream (the policy is fixed at first open).

pub fn write(&mut self, stream_id: u32, data: &[u8], fin: bool) -> Result<()>

Write data on stream_id. Full symbols are emitted immediately; a partial tail is buffered until the next write or fin. With fin set the stream is closed: the buffered tail goes out as the final (short) symbol and a reliable STREAM_FIN announces its index and length.

pub fn pump(&mut self) -> Result<()>

Drain incoming NAK / ACK frames: retransmit NAK’d symbols and advance each stream’s acked frontier (which frees the flow windows). Also resends the STREAM_FIN of any finished-but-unacked stream on a slow cadence, so a terminator lost while other streams are still being written still converges (not only once the final flush begins).

pub fn flush(&mut self, timeout: Duration) -> Result<bool>

Block until every stream is fully acked (all flow windows empty and each finished stream’s frontier past its final symbol) or the timeout elapses. Resends each finished stream’s STREAM_FIN so a lost terminator converges.