diff --git a/src/lib.rs b/src/lib.rs index b2ad3f2..72f210d 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -100,7 +100,13 @@ impl SeqQueue { true } - pub fn receive(&mut self, app: App, seq_num: SeqNum, reply_num: Option, packet: impl IntoRecvData) -> Result { + pub fn receive( + &mut self, + app: App, + seq_num: SeqNum, + reply_num: Option, + packet: impl IntoRecvData, + ) -> Result { let normalized_seq_num = seq_num.wrapping_sub(self.pre_recv_seq_num).wrapping_sub(1); let is_below_range = normalized_seq_num > SeqNum::MAX / 2; let is_above_range = !is_below_range && normalized_seq_num >= self.recv_window.len() as u32;