Struct ReliableSender 

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

Implementations

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

pub fn new(rtt_resend_factor: f32) -> Self

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

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

Trait Implementations

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

fn send_message(&mut self, message: P)

Queues a Message to be transmitted to the remote host into an internal buffer

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