Fix formatting for examples

Signed-off-by: Michael X. Grey <[email protected]>

Author: mxgrey

examples/logging_demo/src/main.rs

@@ -12,25 +12,16 @@ fn main() -> Result<(), RclrsError> {
 
             // You can apply modifiers such as .once() to node.logger()
             // to dictate how the logging behaves.
-            log!(
-                node.logger().once(),
-                "First message: {data}",
-            );
+            log!(node.logger().once(), "First message: {data}",);
 
-            log!(
-                node.logger().skip_first(),
-                "Subsequent message: {data}",
-            );
+            log!(node.logger().skip_first(), "Subsequent message: {data}",);
 
             // You can chain multiple modifiers together.
             log_warn!(
-                node
-                .logger()
-                .skip_first()
-                .throttle(Duration::from_secs(5)),
+                node.logger().skip_first().throttle(Duration::from_secs(5)),
                 "Throttled message: {data}",
             );
-        }
+        },
     )?;
 
     // Any &str can be used as the logger name and have

examples/minimal_client_service/src/minimal_client.rs

@@ -1,6 +1,6 @@
 use anyhow::{Error, Result};
-use rclrs::*;
 use example_interfaces::srv::*;
+use rclrs::*;
 
 fn main() -> Result<(), Error> {
     let mut executor = Context::default_from_env()?.create_basic_executor();
@@ -16,8 +16,7 @@ fn main() -> Result<(), Error> {
         let request = AddTwoInts_Request { a: 41, b: 1 };
 
         println!("Waiting for response");
-        let response: AddTwoInts_Response =
-            client.call(&request).unwrap().await.unwrap();
+        let response: AddTwoInts_Response = client.call(&request).unwrap().await.unwrap();
 
         println!(
             "Result of {} + {} is: {}",

examples/minimal_client_service/src/minimal_client_async.rs

@@ -1,6 +1,6 @@
 use anyhow::{Error, Result};
-use rclrs::*;
 use example_interfaces::srv::*;
+use rclrs::*;
 
 #[tokio::main]
 async fn main() -> Result<(), Error> {
@@ -18,15 +18,14 @@ async fn main() -> Result<(), Error> {
 
     let request = AddTwoInts_Request { a: 41, b: 1 };
 
-    let promise = client.call_then(
-        &request,
-        move |response: AddTwoInts_Response| {
+    let promise = client
+        .call_then(&request, move |response: AddTwoInts_Response| {
             println!(
                 "Result of {} + {} is: {}",
                 request.a, request.b, response.sum,
             );
-        }
-    ).unwrap();
+        })
+        .unwrap();
 
     println!("Waiting for response");
     executor

examples/minimal_client_service/src/minimal_service.rs

@@ -1,11 +1,8 @@
 use anyhow::{Error, Result};
-use rclrs::*;
 use example_interfaces::srv::*;
+use rclrs::*;
 
-fn handle_service(
-    request: AddTwoInts_Request,
-    info: ServiceInfo,
-) -> AddTwoInts_Response {
+fn handle_service(request: AddTwoInts_Request, info: ServiceInfo) -> AddTwoInts_Response {
     let timestamp = info
         .received_timestamp
         .map(|t| format!(" at [{t:?}]"))
@@ -22,12 +19,9 @@ fn main() -> Result<(), Error> {
 
     let node = executor.create_node("minimal_service")?;
 
-    let _server = node
-        .create_service::<AddTwoInts, _>("add_two_ints", handle_service)?;
+    let _server = node.create_service::<AddTwoInts, _>("add_two_ints", handle_service)?;
 
     println!("Starting server");
-    executor
-        .spin(SpinOptions::default())
-        .first_error()?;
+    executor.spin(SpinOptions::default()).first_error()?;
     Ok(())
 }

examples/minimal_pub_sub/src/minimal_subscriber.rs

@@ -17,8 +17,6 @@ fn main() -> Result<(), Error> {
     )?;
 
     println!("Waiting for messages...");
-    executor
-        .spin(SpinOptions::default())
-        .first_error()?;
+    executor.spin(SpinOptions::default()).first_error()?;
     Ok(())
 }

examples/minimal_pub_sub/src/minimal_two_nodes.rs

@@ -17,12 +17,10 @@ impl MinimalSubscriberNode {
     pub fn new(executor: &Executor, name: &str, topic: &str) -> Result<Self, RclrsError> {
         let node = executor.create_node(name)?;
 
-        let worker = node.create_worker::<SubscriptionData>(
-            SubscriptionData {
-                node: Arc::clone(&node),
-                num_messages: 0,
-            }
-        );
+        let worker = node.create_worker::<SubscriptionData>(SubscriptionData {
+            node: Arc::clone(&node),
+            num_messages: 0,
+        });
 
         let subscription = worker.create_subscription(
             topic,
@@ -34,7 +32,7 @@ impl MinimalSubscriberNode {
                     data.node.name(),
                     data.num_messages,
                 );
-            }
+            },
         )?;
 
         Ok(MinimalSubscriberNode { subscription })
@@ -66,9 +64,6 @@ fn main() -> Result<(), Error> {
         }
     });
 
-    executor
-        .spin(rclrs::SpinOptions::default())
-        .first_error()?;
+    executor.spin(rclrs::SpinOptions::default()).first_error()?;
     Ok(())
 }
-

examples/minimal_pub_sub/src/zero_copy_subscriber.rs

@@ -9,15 +9,14 @@ fn main() -> Result<(), Error> {
     let worker = node.create_worker::<usize>(0);
     let _subscription = worker.create_subscription::<example_interfaces::msg::UInt32, _>(
         "topic",
-        move |num_messages: &mut usize, msg: ReadOnlyLoanedMessage<example_interfaces::msg::UInt32>| {
+        move |num_messages: &mut usize,
+              msg: ReadOnlyLoanedMessage<example_interfaces::msg::UInt32>| {
             *num_messages += 1;
             println!("I heard: '{}'", msg.data);
             println!("(Got {} messages so far)", *num_messages);
         },
     )?;
 
-    executor
-        .spin(SpinOptions::default())
-        .first_error()?;
+    executor.spin(SpinOptions::default()).first_error()?;
     Ok(())
 }

examples/parameter_demo/src/main.rs

@@ -10,12 +10,10 @@ fn main() -> Result<(), RclrsError> {
         .default("Hello".into())
         .mandatory()?;
 
-    let _subscription = node.create_subscription(
-        "greet",
-        move |msg: example_interfaces::msg::String| {
+    let _subscription =
+        node.create_subscription("greet", move |msg: example_interfaces::msg::String| {
             println!("{}, {}", greeting.get(), msg.data);
-        }
-    )?;
+        })?;
 
     println!(
         "Ready to provide a greeting. \

examples/rust_pubsub/src/simple_publisher.rs

@@ -9,9 +9,7 @@ struct SimplePublisherNode {
 impl SimplePublisherNode {
     fn new(executor: &Executor) -> Result<Self, RclrsError> {
         let node = executor.create_node("simple_publisher").unwrap();
-        let publisher = node
-            .create_publisher("publish_hello")
-            .unwrap();
+        let publisher = node.create_publisher("publish_hello").unwrap();
         Ok(Self { publisher })
     }
 

examples/rust_pubsub/src/simple_subscriber.rs

@@ -1,8 +1,5 @@
 use rclrs::*;
-use std::{
-    thread,
-    time::Duration,
-};
+use std::{thread, time::Duration};
 use std_msgs::msg::String as StringMsg;
 
 pub struct SimpleSubscriptionNode {

examples/worker_demo/src/main.rs

@@ -12,7 +12,7 @@ fn main() -> Result<(), RclrsError> {
         "input_topic",
         move |data: &mut String, msg: example_interfaces::msg::String| {
             *data = msg.data;
-        }
+        },
     )?;
 
     // // Use this timer-based implementation when timers are available instead
@@ -28,20 +28,15 @@ fn main() -> Result<(), RclrsError> {
     //     }
     // )?;
 
-    std::thread::spawn(move || {
-        loop {
-            std::thread::sleep(std::time::Duration::from_secs(1));
-            let publisher = Arc::clone(&publisher);
-            let _ = worker.run(move |data: &mut String| {
-                let msg = example_interfaces::msg::String {
-                    data: data.clone()
-                };
-                publisher.publish(msg).unwrap();
-            });
-        }
+    std::thread::spawn(move || loop {
+        std::thread::sleep(std::time::Duration::from_secs(1));
+        let publisher = Arc::clone(&publisher);
+        let _ = worker.run(move |data: &mut String| {
+            let msg = example_interfaces::msg::String { data: data.clone() };
+            publisher.publish(msg).unwrap();
+        });
     });
 
-
     println!(
         "Beginning repeater... \n >> \
         Publish a std_msg::msg::String to \"input_topic\" and we will periodically republish it to \"output_topic\".\n\n\