Struct ReliableSender 

pub struct ReliableSender<P: Send + Sync> { /* private fields */ }

Retransmit-on-timeout sender that tracks unacknowledged messages and re-queues them after an RTT-based interval.

Implementations

impl<P: Send + Sync> ReliableSender<P>

pub fn new(rtt_resend_factor: f32, max_queue_depth: Option<usize>) -> Self

Creates a ReliableSender with the given RTT resend factor and optional queue-depth cap.

pub fn take_next_messages(&mut self) -> VecDeque<(MessageIndex, P)>

Drains and returns all messages currently staged for transmission this tick.

pub fn deliver_message(&mut self, message_index: &MessageIndex) -> Option<P>

Acknowledges delivery of message_index, removing it from the retransmit buffer and returning the message.

Trait Implementations

impl<P: Send + Sync + Clone> ChannelSender<P> for ReliableSender<P>

fn send_message(&mut self, message: P) -> bool

Queues a Message to be transmitted to the remote host into an internal buffer. Returns true if the message was accepted, false if the channel’s queue was full and the message was dropped (reliable) or the oldest entry was evicted to make room (unreliable).

fn collect_messages(&mut self, now: &Instant, rtt_millis: &f32)

For reliable channels, will collect any Messages that need to be resent

fn has_messages(&self) -> bool

Returns true if there are queued Messages ready to be written

fn notify_message_delivered(&mut self, message_index: &MessageIndex)

Called when it receives acknowledgement that a Message has been received