diff --git a/src/main.rs b/src/main.rs
index 785d9da..f9e39f7 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -95,6 +95,7 @@ fn mopp(speed: u8, data: &[u8]) -> Vec<u8> {
     );
 
     let mut res = Vec::<u8>::new();
+    
     for i in (0..m.len()).step_by(8) {
         let value = u8::from_str_radix(&m[i..i + 8], 2).unwrap();
         res.push(value);
@@ -118,24 +119,23 @@ fn broadcast(
     }
 }
 
-fn remove_old_clients(socket: &UdpSocket,
-    subscribers: &mut HashMap<String, DateTime<Local>>,) {
-        let timestamp = Local::now();
+fn remove_old_clients(socket: &UdpSocket, subscribers: &mut HashMap<String, DateTime<Local>>) {
+    let timestamp = Local::now();
 
-        debug!("Number of clients: {}", subscribers.len());
+    debug!("Number of clients: {}", subscribers.len());
 
-        for cl in &*subscribers {
-            if *cl.1 + Duration::seconds(CLIENT_TIMEOUT as i64) < timestamp {
-                debug!("Removing old client {}", cl.0);
-                socket
-                    .send_to(mopp(MY_SPEED, b":bye").as_slice(), &cl.0)
-                    .unwrap();
-            }
+    for cl in &*subscribers {
+        if *cl.1 + Duration::seconds(CLIENT_TIMEOUT as i64) < timestamp {
+            debug!("Removing old client {}", cl.0);
+            socket
+                .send_to(mopp(MY_SPEED, b":bye").as_slice(), &cl.0)
+                .unwrap();
         }
-
-        subscribers.retain(|_, val| *val + Duration::seconds(CLIENT_TIMEOUT as i64) >= timestamp);
     }
 
+    subscribers.retain(|_, val| *val + Duration::seconds(CLIENT_TIMEOUT as i64) >= timestamp);
+}
+
 fn main() -> std::io::Result<()> {
     env_logger::init();
 
@@ -204,6 +204,6 @@ fn main() -> std::io::Result<()> {
             debug!("Ignoring unknown client {client_addr}");
         }
 
-       remove_old_clients(&socket, &mut subscribers);
+        remove_old_clients(&socket, &mut subscribers);
     }
 }