fix clippy

8xFF · Nov 21, 2024 · c86899d · c86899d
1 parent 890aea4
commit c86899d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/packages/media_core/src/cluster/room/metadata.rs b/packages/media_core/src/cluster/room/metadata.rs
@@ -250,7 +250,7 @@ impl<Endpoint: Debug + Hash + Eq + Copy> RoomMetadata<Endpoint> {
             None
         };
 
-        let subscribers = self.peers_map_subscribers.iter().map(|a| a.clone()).collect::<Vec<_>>();
+        let subscribers = self.peers_map_subscribers.iter().copied().collect::<Vec<_>>();
         if let Some(info) = info {
             log::info!("[ClusterRoom {}] cluster: peer {} joined => fire event to {:?}", self.room, info.peer, subscribers);
             self.cluster_peers.insert(peer_key, info.clone());
@@ -273,7 +273,7 @@ impl<Endpoint: Debug + Hash + Eq + Copy> RoomMetadata<Endpoint> {
             None
         };
 
-        let subscribers = self.tracks_map_subscribers.iter().map(|a| a.clone()).collect::<Vec<_>>();
+        let subscribers = self.tracks_map_subscribers.iter().copied().collect::<Vec<_>>();
         if let Some(info) = info {
             log::info!(
                 "[ClusterRoom {}] cluster: peer ({}) started track {}) => fire event to {:?}",
@@ -310,7 +310,7 @@ impl<Endpoint: Debug + Hash + Eq + Copy> RoomMetadata<Endpoint> {
             None
         };
 
-        let subscribers = return_if_none!(self.peers_tracks_subs.get(&peer_map)).iter().map(|a| a.clone()).collect::<Vec<_>>();
+        let subscribers = return_if_none!(self.peers_tracks_subs.get(&peer_map)).iter().copied().collect::<Vec<_>>();
         if let Some(info) = info {
             log::info!(
                 "[ClusterRoom {}] cluster: peer ({}) started track {}) => fire event to {:?}",

diff --git a/packages/media_runner/src/worker.rs b/packages/media_runner/src/worker.rs
@@ -740,7 +740,7 @@ mod test {
 
     #[test]
     fn smallmap_collision() {
-        for i in 0..1000_000 {
+        for i in 0..1_000_000 {
             let mut map = indexmap::IndexMap::new();
             let webrtc = MediaClusterEndpoint::Webrtc(WebrtcSession::from(rand::random::<usize>()));
             map.insert(webrtc, ());
@@ -753,11 +753,11 @@ mod test {
             map.swap_remove(&webrtc);
 
             assert_eq!(map.len(), 1);
-            assert_eq!(map.is_empty(), false, "first failsed, cycle {i} {webrtc:?} {rtpengine:?}");
+            assert!(!map.is_empty(), "first failsed, cycle {i} {webrtc:?} {rtpengine:?}");
 
             map.swap_remove(&rtpengine);
             assert_eq!(map.len(), 0);
-            assert_eq!(map.is_empty(), true, "second failsed, cycle {i} {webrtc:?} {rtpengine:?}");
+            assert!(map.is_empty(), "second failsed, cycle {i} {webrtc:?} {rtpengine:?}");
         }
     }
 }