From cd953b6f6353bdc9d2b18c1593e6b39cdaf33699 Mon Sep 17 00:00:00 2001
From: Carter <carter@amp>
Date: Thu, 15 Aug 2024 14:57:52 -0600
Subject: [PATCH] Run cargo fmt

---
 roslibrust/src/ros1/node/handle.rs                | 3 +--
 roslibrust/src/ros1/subscriber.rs                 | 4 +++-
 roslibrust/tests/ros1_native_integration_tests.rs | 5 +----
 3 files changed, 5 insertions(+), 7 deletions(-)

diff --git a/roslibrust/src/ros1/node/handle.rs b/roslibrust/src/ros1/node/handle.rs
index a8b4762..3ef3e6e 100644
--- a/roslibrust/src/ros1/node/handle.rs
+++ b/roslibrust/src/ros1/node/handle.rs
@@ -2,8 +2,7 @@ use super::actor::{Node, NodeServerHandle};
 use crate::{
     ros1::{
         names::Name, publisher::Publisher, service_client::ServiceClient, subscriber::Subscriber,
-        subscriber::SubscriberAny,
-        NodeError, ServiceServer,
+        subscriber::SubscriberAny, NodeError, ServiceServer,
     },
     ServiceFn,
 };
diff --git a/roslibrust/src/ros1/subscriber.rs b/roslibrust/src/ros1/subscriber.rs
index 057c016..900453b 100644
--- a/roslibrust/src/ros1/subscriber.rs
+++ b/roslibrust/src/ros1/subscriber.rs
@@ -178,7 +178,9 @@ async fn establish_publisher_connection(
     stream.write_all(&conn_header_bytes[..]).await?;
 
     if let Ok(responded_header) = tcpros::receive_header(&mut stream).await {
-        if conn_header.md5sum == Some("*".to_string()) || conn_header.md5sum == responded_header.md5sum {
+        if conn_header.md5sum == Some("*".to_string())
+            || conn_header.md5sum == responded_header.md5sum
+        {
             log::debug!(
                 "Established connection with publisher for {:?}",
                 conn_header.topic
diff --git a/roslibrust/tests/ros1_native_integration_tests.rs b/roslibrust/tests/ros1_native_integration_tests.rs
index 42a9c7d..710be2f 100644
--- a/roslibrust/tests/ros1_native_integration_tests.rs
+++ b/roslibrust/tests/ros1_native_integration_tests.rs
@@ -24,10 +24,7 @@ mod tests {
             .await
             .unwrap();
 
-        let mut subscriber = nh
-            .subscribe_any("/test_subscribe_any", 1)
-            .await
-            .unwrap();
+        let mut subscriber = nh.subscribe_any("/test_subscribe_any", 1).await.unwrap();
 
         publisher
             .publish(&std_msgs::String {