Struct naia_shared::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

impl MessageChannelSender for ReliableSender<MessageContainer>

fn write_messages( &mut self, message_kinds: &MessageKinds, converter: &mut dyn LocalEntityAndGlobalEntityConverterMut, writer: &mut BitWriter, has_written: &mut bool ) -> Option<Vec<MessageIndex>>

Gets Messages from the internal buffer and writes it to the BitWriter