Format fix.

Signed-off-by: Agustin Alba Chicar <[email protected]>

Author: agalbachicar

rclrs/src/lib.rs

@@ -19,8 +19,8 @@ mod qos;
 mod service;
 mod subscription;
 mod time;
-mod timer;
 mod time_source;
+mod timer;
 mod vendor;
 mod wait;
 
@@ -49,8 +49,8 @@ pub use rcl_bindings::rmw_request_id_t;
 pub use service::*;
 pub use subscription::*;
 pub use time::*;
-pub use timer::*;
 use time_source::*;
+pub use timer::*;
 pub use wait::*;
 
 /// Polls the node for new messages and executes the corresponding callbacks.

rclrs/src/node.rs

@@ -16,7 +16,7 @@ use crate::{
     rcl_bindings::*, Client, ClientBase, Clock, Context, ContextHandle, GuardCondition, LogParams,
     Logger, ParameterBuilder, ParameterInterface, ParameterVariant, Parameters, Publisher,
     QoSProfile, RclrsError, Service, ServiceBase, Subscription, SubscriptionBase,
-    SubscriptionCallback, Timer, TimerCallback, TimeSource, ToLogParams, ENTITY_LIFECYCLE_MUTEX,
+    SubscriptionCallback, TimeSource, Timer, TimerCallback, ToLogParams, ENTITY_LIFECYCLE_MUTEX,
 };
 
 /// Constant conversion from seconds to nanoseconds
@@ -350,15 +350,18 @@ impl Node {
         period_ns: i64,
         context: &Context,
         callback: Option<TimerCallback>,
-        clock: Option<Clock>
+        clock: Option<Clock>,
     ) -> Result<Arc<Timer>, RclrsError> {
         let clock_used = match clock {
             Some(value) => value,
             None => self.get_clock(),
         };
         let timer = Timer::new_with_callback(&clock_used, &context, period_ns, callback)?;
         let timer = Arc::new(timer);
-        self.timers_mtx.lock().unwrap().push(Arc::downgrade(&timer) as Weak<Timer>);
+        self.timers_mtx
+            .lock()
+            .unwrap()
+            .push(Arc::downgrade(&timer) as Weak<Timer>);
         Ok(timer)
     }