diff --git a/mavlink/tests/tcp_loopback_async_tests.rs b/mavlink/tests/tcp_loopback_async_tests.rs
index edd56ba5958a74fffb4aeac56d7d4ce51733c8ef..860ce0b10e2f9e021f2e475b5daf5e4823a8184a 100644
--- a/mavlink/tests/tcp_loopback_async_tests.rs
+++ b/mavlink/tests/tcp_loopback_async_tests.rs
@@ -20,8 +20,9 @@ mod test_tcp_connections {
 
         let server_thread = tokio::spawn(async move {
             //TODO consider using get_available_port to use a random port
-            let mut server =
-                mavlink::connect_async("tcpin:0.0.0.0:14551").await.expect("Couldn't create server");
+            let mut server = mavlink::connect_async("tcpin:0.0.0.0:14551")
+                .await
+                .expect("Couldn't create server");
 
             #[cfg(feature = "signing")]
             server.setup_signing(Some(singing_cfg_server));
@@ -53,8 +54,9 @@ mod test_tcp_connections {
         tokio::spawn(async move {
             let msg =
                 mavlink::common::MavMessage::HEARTBEAT(crate::test_shared::get_heartbeat_msg());
-            let mut client =
-                mavlink::connect_async("tcpout:127.0.0.1:14551").await.expect("Couldn't create client");
+            let mut client = mavlink::connect_async("tcpout:127.0.0.1:14551")
+                .await
+                .expect("Couldn't create client");
 
             #[cfg(feature = "signing")]
             client.setup_signing(Some(singing_cfg_client));
diff --git a/mavlink/tests/udp_loopback_async_tests.rs b/mavlink/tests/udp_loopback_async_tests.rs
index 3d6b46d2369c7b5c4b565f72004cd2010b4ec528..4b3934523e96bdf46b4105fe26b24ad206933fad 100644
--- a/mavlink/tests/udp_loopback_async_tests.rs
+++ b/mavlink/tests/udp_loopback_async_tests.rs
@@ -8,15 +8,18 @@ mod test_udp_connections {
     pub async fn test_udp_loopback() {
         const RECEIVE_CHECK_COUNT: i32 = 3;
 
-        let server = mavlink::connect_async("udpin:0.0.0.0:14552").await.expect("Couldn't create server");
+        let server = mavlink::connect_async("udpin:0.0.0.0:14552")
+            .await
+            .expect("Couldn't create server");
 
         // have the client send one heartbeat per second
         tokio::spawn({
             async move {
                 let msg =
                     mavlink::common::MavMessage::HEARTBEAT(crate::test_shared::get_heartbeat_msg());
-                let client =
-                    mavlink::connect_async("udpout:127.0.0.1:14552").await.expect("Couldn't create client");
+                let client = mavlink::connect_async("udpout:127.0.0.1:14552")
+                    .await
+                    .expect("Couldn't create client");
                 loop {
                     client.send_default(&msg).await.ok();
                 }