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