diff --git a/mavlink/tests/tcp_loopback_async_tests.rs b/mavlink/tests/tcp_loopback_async_tests.rs index edd56ba595..860ce0b10e 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 3d6b46d236..4b3934523e 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(); }