Struct ReliableTransport 

pub struct ReliableTransport { /* private fields */ }

Reliable transport layer

Implementations

impl ReliableTransport

pub fn new(config: ReliableConfig) -> Self

Create a new reliable transport

pub fn send(&mut self, data: Bytes) -> Result<(u32, Bytes)>

Queue a packet for sending

Returns the packet ID and the data to send

pub fn receive(&mut self, packet_id: u32, data: Bytes) -> Result<Option<Bytes>>

Process received packet

Returns the payload if this is the next expected packet, otherwise buffers it for later delivery.

pub fn process_acks(&mut self, acks: &[u32])

Process received ACKs

pub fn get_acks(&mut self) -> Vec<u32>

Get ACKs to send

pub fn should_send_ack(&self) -> bool

Check if we should send a standalone ACK

pub fn ack_sent(&mut self)

Mark ACK as sent

pub fn get_retransmits(&mut self) -> Vec<(u32, Bytes)>

Get packets that need retransmission

pub fn has_pending(&self) -> bool

Check if there are pending packets

pub fn next_timeout(&self) -> Option<Duration>

Get next timeout (when we need to check for retransmits)