revert to indexset

Signed-off-by: iGxnon <igxnon@gmail.com>

Cargo.toml

@@ -26,6 +26,7 @@ tokio-util = { version = "0.7.9", features = ["codec", "net", "io-util"] }
 [dev-dependencies]
 criterion = { version = "0.5", features = ["async_futures"] }
 env_logger = "0.11.1"
+indexmap = "2"
 minitrace = { version = "0.6", features = ["enable"] }
 rand = "0.8"
 

src/codec/decoder/dedup.rs

@@ -240,12 +240,12 @@ where
 #[cfg(test)]
 mod test {
 
-    use std::collections::BTreeSet;
     use std::ops::Sub;
 
     use bytes::Bytes;
     use futures::StreamExt;
     use futures_async_stream::stream;
+    use indexmap::IndexSet;
 
     use super::*;
     use crate::errors::CodecError;
@@ -409,8 +409,8 @@ mod test {
             .take(scale)
             .collect::<Vec<_>>();
 
-        let idx1_set: BTreeSet<u32> = idx1.clone().into_iter().collect();
-        let idx2_set: BTreeSet<u32> = idx2.clone().into_iter().collect();
+        let idx1_set: IndexSet<u32> = idx1.clone().into_iter().collect();
+        let idx2_set: IndexSet<u32> = idx2.clone().into_iter().collect();
         let diff = idx2_set.sub(&idx1_set);
 
         let frame = {
@@ -428,10 +428,7 @@ mod test {
             window: DuplicateWindow::default(),
             outgoing_ack_tx,
         };
-        assert_eq!(
-            dedup.next().await.unwrap().unwrap(),
-            frame_set(idx1_set.clone())
-        );
+        assert_eq!(dedup.next().await.unwrap().unwrap(), frame_set(idx1_set));
 
         if diff.is_empty() {
             assert!(dedup.next().await.is_none());