From f81f0b4118f073ced6270551ef37dfd7b75921b3 Mon Sep 17 00:00:00 2001
From: pv42 <pv42.97@gmail.com>
Date: Sun, 1 Sep 2024 16:17:44 +0200
Subject: [PATCH] fix: fmt
---
mavlink/tests/tcp_loopback_async_tests.rs | 10 ++++++----
mavlink/tests/udp_loopback_async_tests.rs | 9 ++++++---
2 files changed, 12 insertions(+), 7 deletions(-)
diff --git a/mavlink/tests/tcp_loopback_async_tests.rs b/mavlink/tests/tcp_loopback_async_tests.rs
index edd56ba..860ce0b 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 3d6b46d..4b39345 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();
}
--
GitLab