naia_shared/messages/channels/receivers/
unordered_reliable_receiver.rs

1use crate::{
2    messages::channels::receivers::reliable_message_receiver::{
3        ReceiverArranger, ReliableMessageReceiver,
4    },
5    types::MessageIndex,
6    MessageContainer,
7};
8
9pub type UnorderedReliableReceiver = ReliableMessageReceiver<UnorderedArranger>;
10
11impl UnorderedReliableReceiver {
12    pub fn new() -> Self {
13        Self::with_arranger(UnorderedArranger)
14    }
15}
16
17// UnorderedArranger
18pub struct UnorderedArranger;
19
20impl ReceiverArranger for UnorderedArranger {
21    fn process(
22        &mut self,
23        _start_message_index: MessageIndex,
24        _end_message_index: MessageIndex,
25        message: MessageContainer,
26    ) -> Vec<MessageContainer> {
27        let mut output = Vec::new();
28        output.push(message);
29        output
30    }
31}