make ci green again

Author: darioalessandro

videocall-client/src/client/video_call_client.rs

@@ -177,15 +177,14 @@ impl VideoCallClient {
                             Ok(mut inner) => {
                                 inner.peer_decode_manager.run_peer_monitor();
                                 on_connection_lost.emit(());
-                            },
+                            }
                             Err(_) => {
                                 error!("Unable to borrow inner -- not starting peer monitor");
                             }
                         }
                     }
                 })
             },
-
         };
         info!(
             "webtransport connect = {}",

videocall-client/src/connection/connection.rs

@@ -58,7 +58,9 @@ impl Connection {
         let mut connection = Self {
             task: Rc::new(Task::connect(webtransport, options)?),
             heartbeat: None,
-            heartbeat_monitor: Some(Interval::new(5000, move || {monitor.emit(());})),
+            heartbeat_monitor: Some(Interval::new(5000, move || {
+                monitor.emit(());
+            })),
             status,
             aes,
         };

videocall-client/src/decode/hash_map_with_ordered_keys.rs

@@ -77,20 +77,20 @@ impl<K: Ord + Hash + Clone, V> HashMapWithOrderedKeys<K, V> {
 
     pub fn remove_if<F>(&mut self, predicate: F)
     where
-        F: Fn(&mut V) -> bool
+        F: Fn(&mut V) -> bool,
     {
         let mut keys_to_remove = Vec::new();
 
-        for key in &self.keys{
+        for key in &self.keys {
             if let Some(value) = self.map.get_mut(key) {
-                if !predicate(value){
+                if !predicate(value) {
                     keys_to_remove.push(key.clone());
-               }
+                }
             }
         }
 
-         for key in &keys_to_remove {
-            self.map.remove(&key);
+        for key in &keys_to_remove {
+            self.map.remove(key);
             self.keys.retain(|k| k != key);
         }
     }

videocall-client/src/decode/peer_decode_manager.rs

@@ -76,7 +76,7 @@ impl Peer {
             video_canvas_id,
             screen_canvas_id,
             aes,
-            heartbeat_count: 1
+            heartbeat_count: 1,
         }
     }
 
@@ -160,12 +160,15 @@ impl Peer {
     }
 
     pub fn check_heartbeat(&mut self) -> bool {
-       if self.heartbeat_count != 0 {
+        if self.heartbeat_count != 0 {
             self.heartbeat_count = 0;
             return true;
         }
-        debug!("---@@@--- detected heartbeat stop for {}", self.email.clone());
-        return false;
+        debug!(
+            "---@@@--- detected heartbeat stop for {}",
+            self.email.clone()
+        );
+        false
     }
 }
 
@@ -214,7 +217,7 @@ impl PeerDecodeManager {
                 Ok((MediaType::HEARTBEAT, _)) => {
                     peer.on_heartbeat();
                     Ok(())
-                },
+                }
                 Ok((media_type, decode_status)) => {
                     if decode_status.first_frame {
                         self.on_first_frame.emit((email.clone(), media_type));