Format

Signed-off-by: Luca Della Vedova <[email protected]>

Author: luca-della-vedova

rclrs/src/dynamic_message/dynamic_publisher.rs

@@ -163,20 +163,18 @@ mod tests {
         let namespace = "/test_dynamic_publishers_graph";
         let graph = construct_test_graph(namespace)?;
 
-        let node_1_empty_publisher = graph.node1.create_dynamic_publisher(
-            "test_msgs/msg/Empty".try_into()?,
-            "graph_test_topic_1",
-        )?;
+        let node_1_empty_publisher = graph
+            .node1
+            .create_dynamic_publisher("test_msgs/msg/Empty".try_into()?, "graph_test_topic_1")?;
         let topic1 = node_1_empty_publisher.topic_name();
         let node_1_basic_types_publisher = graph.node1.create_dynamic_publisher(
             "test_msgs/msg/BasicTypes".try_into()?,
             "graph_test_topic_2",
         )?;
         let topic2 = node_1_basic_types_publisher.topic_name();
-        let node_2_default_publisher = graph.node2.create_dynamic_publisher(
-            "test_msgs/msg/Defaults".try_into()?,
-            "graph_test_topic_3",
-        )?;
+        let node_2_default_publisher = graph
+            .node2
+            .create_dynamic_publisher("test_msgs/msg/Defaults".try_into()?, "graph_test_topic_3")?;
         let topic3 = node_2_default_publisher.topic_name();
 
         std::thread::sleep(std::time::Duration::from_millis(100));

rclrs/src/dynamic_message/dynamic_subscription.rs

@@ -13,8 +13,8 @@ use super::{
 use crate::rcl_bindings::*;
 use crate::{
     MessageInfo, Node, NodeHandle, RclPrimitive, RclPrimitiveHandle, RclPrimitiveKind, RclrsError,
-    SubscriptionHandle, SubscriptionOptions, ToResult, Waitable, WaitableLifecycle, WorkScope,
-    Worker, WorkerCommands, ENTITY_LIFECYCLE_MUTEX, RclrsErrorFilter,
+    RclrsErrorFilter, SubscriptionHandle, SubscriptionOptions, ToResult, Waitable,
+    WaitableLifecycle, WorkScope, Worker, WorkerCommands, ENTITY_LIFECYCLE_MUTEX,
 };
 
 /// Struct for receiving messages whose type is not know at compile time.

rclrs/src/worker.rs

@@ -608,9 +608,7 @@ mod tests {
         );
 
         let promise = worker.listen_until(move |payload| {
-            if payload.service_count > 0
-                && payload.subscription_count > 0
-            {
+            if payload.service_count > 0 && payload.subscription_count > 0 {
                 #[cfg(feature = "dyn_msg")]
                 if payload.dynamic_subscription_count > 0 {
                     Some(*payload)