rustfmt

aggligator-util/src/transport/tcp.rs

@@ -390,7 +390,9 @@ impl AcceptingTransport for TcpAcceptor {
 
             // Find local interface.
             let Some(interface) = local_interface_for_ip(local.ip())? else {
-                tracing::warn!("Interface for incoming connection from {remote} to {local} not found, rejecting.");
+                tracing::warn!(
+                    "Interface for incoming connection from {remote} to {local} not found, rejecting."
+                );
                 continue;
             };
 

aggligator/src/agg/task.rs

@@ -1412,7 +1412,7 @@ where
 
         // Extract message and link used for sending.
         let mut status = packet.status.borrow_mut();
-        let SentReliableStatus::ResendQueued {msg: reliable_msg} = &*status else {
+        let SentReliableStatus::ResendQueued { msg: reliable_msg } = &*status else {
             unreachable!("message was not queued for resending")
         };
 
@@ -1815,7 +1815,7 @@ where
 
     /// Sends statistics data.
     fn send_stats(&mut self) {
-        let Some (interval) = self.cfg.stats_intervals.iter().min() else { return };
+        let Some(interval) = self.cfg.stats_intervals.iter().min() else { return };
         if self.stats_last_sent.elapsed() >= *interval {
             self.stats_last_sent = Instant::now();
 

aggligator/src/connect.rs

@@ -423,9 +423,12 @@ where
                     server_id,
                     connection_id: encrypted_conn_id,
                     existing_connection,
-                    user_data: remote_user_data, cfg
+                    user_data: remote_user_data,
+                    cfg,
                 } = LinkMsg::recv(&mut rx).await?
-                    else { return Err::<_, IncomingError>(protocol_err!("expected Connect message").into()) };
+                else {
+                    return Err::<_, IncomingError>(protocol_err!("expected Connect message").into());
+                };
 
                 let shared_secret = server_secret.diffie_hellman(&client_public_key);
                 let conn_id = encrypted_conn_id.decrypt(&shared_secret);

aggligator/src/control.rs

@@ -308,9 +308,11 @@ where
                 public_key: server_public_key,
                 server_id,
                 cfg,
-                user_data: remote_user_data
+                user_data: remote_user_data,
             } = LinkMsg::recv(&mut rx).await?
-                else { return Err::<_, AddLinkError>(protocol_err!("expected Welcome message").into()) };
+            else {
+                return Err::<_, AddLinkError>(protocol_err!("expected Welcome message").into());
+            };
 
             let shared_secret = client_secret.diffie_hellman(&server_public_key);