Run cargo fmt

RosLibRust · Aug 15, 2024 · cd953b6 · cd953b6
1 parent 09b3c5e
commit cd953b6
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 7 deletions.
diff --git 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
@@ -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
@@ -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 {