Struct naia_shared::ReliableSender
source · pub struct ReliableSender<P: Send + Sync> { /* private fields */ }
Implementations§
source§impl<P: Send + Sync> ReliableSender<P>
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§
source§impl<P: Send + Sync + Clone> ChannelSender<P> for ReliableSender<P>
impl<P: Send + Sync + Clone> ChannelSender<P> for ReliableSender<P>
source§fn send_message(&mut self, message: P)
fn send_message(&mut self, message: P)
Queues a Message to be transmitted to the remote host into an internal buffer
source§fn collect_messages(&mut self, now: &Instant, rtt_millis: &f32)
fn collect_messages(&mut self, now: &Instant, rtt_millis: &f32)
For reliable channels, will collect any Messages that need to be resent
source§fn has_messages(&self) -> bool
fn has_messages(&self) -> bool
Returns true if there are queued Messages ready to be written
source§fn notify_message_delivered(&mut self, message_index: &MessageIndex)
fn notify_message_delivered(&mut self, message_index: &MessageIndex)
Called when it receives acknowledgement that a Message has been received
source§impl MessageChannelSender for ReliableSender<MessageContainer>
impl MessageChannelSender for ReliableSender<MessageContainer>
source§fn write_messages(
&mut self,
message_kinds: &MessageKinds,
converter: &mut dyn LocalEntityAndGlobalEntityConverterMut,
writer: &mut BitWriter,
has_written: &mut bool
) -> Option<Vec<MessageIndex>>
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
Auto Trait Implementations§
impl<P> RefUnwindSafe for ReliableSender<P>where
P: RefUnwindSafe,
impl<P> Send for ReliableSender<P>
impl<P> Sync for ReliableSender<P>
impl<P> Unpin for ReliableSender<P>where
P: Unpin,
impl<P> UnwindSafe for ReliableSender<P>where
P: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more