Struct ReliableChannel 

pub struct ReliableChannel { /* private fields */ }

Reliable delivery channel with retransmission and RTT estimation.

Implementations

impl ReliableChannel

pub fn new(channel_id: u8, config: TransportConfig) -> Self

pub fn channel_id(&self) -> u8

pub fn stats(&self) -> &TransportStats

pub fn rtt_ms(&self) -> f64

pub fn local_sequence(&self) -> u16

pub fn remote_sequence(&self) -> u16

pub fn send(&mut self, data: Vec<u8>) -> u16

Queue data for reliable sending. Returns the assigned sequence number.

pub fn flush(&mut self, now: Instant) -> Vec<(PacketHeader, Vec<u8>)>

Flush the send queue, producing packets ready to send.

pub fn receive(&mut self, header: &PacketHeader, payload: Vec<u8>, now: Instant)

Process an incoming reliable packet.

pub fn drain_received(&mut self) -> Vec<Vec<u8>>

Drain delivered messages in order.

pub fn drain_pending_acks(&mut self) -> Vec<u16>

Get pending acks to piggyback on outgoing packets.

pub fn in_flight(&self) -> usize

Number of unacked packets in the send window.

pub fn is_congested(&self) -> bool

Whether the send window is full.

pub fn reset(&mut self)

Reset the channel state.