style: apply cargo +nightly fmt

Author: azerupi

rclrs/src/executor/tokio_executor.rs

@@ -21,26 +21,29 @@
 //! Code that needs work confined to spinning should put it in an entity callback
 //! rather than a spawned task.
 
-use std::any::Any;
-use std::collections::HashMap;
-use std::panic::AssertUnwindSafe;
-use std::sync::{
-    atomic::{AtomicBool, AtomicU64, AtomicUsize, Ordering},
-    Arc, Mutex,
+use std::{
+    any::Any,
+    collections::HashMap,
+    panic::AssertUnwindSafe,
+    sync::{
+        atomic::{AtomicBool, AtomicU64, AtomicUsize, Ordering},
+        Arc, Mutex,
+    },
+    time::{Duration, Instant},
 };
-use std::time::{Duration, Instant};
 
 use futures::future::BoxFuture;
 use tokio::sync::{
     mpsc::{UnboundedReceiver, UnboundedSender},
     watch, Notify,
 };
 
-use crate::rcl_bindings::{rcl_timer_get_time_until_next_call, rcl_timer_is_ready, rcl_timer_t};
 use crate::{
-    log_error, Context, ExecutorChannel, ExecutorRuntime, ExecutorWorkerOptions, OnReadyHandle,
-    PayloadTask, RclReturnCode, RclrsError, ReadyKind, SpinConditions, ToResult, Waitable,
-    WeakActivityListener, WorkerChannel,
+    log_error,
+    rcl_bindings::{rcl_timer_get_time_until_next_call, rcl_timer_is_ready, rcl_timer_t},
+    Context, ExecutorChannel, ExecutorRuntime, ExecutorWorkerOptions, OnReadyHandle, PayloadTask,
+    RclReturnCode, RclrsError, ReadyKind, SpinConditions, ToResult, Waitable, WeakActivityListener,
+    WorkerChannel,
 };
 
 use super::Executor;
@@ -1002,11 +1005,14 @@ impl CreateTokioExecutor for Context {
 #[cfg(test)]
 mod tests {
     use crate::*;
-    use ros_env::test_msgs;
-    use ros_env::test_msgs::msg;
-    use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering};
-    use std::sync::Arc;
-    use std::time::{Duration, Instant};
+    use ros_env::{test_msgs, test_msgs::msg};
+    use std::{
+        sync::{
+            atomic::{AtomicBool, AtomicUsize, Ordering},
+            Arc,
+        },
+        time::{Duration, Instant},
+    };
 
     /// The executor can adopt the current Tokio runtime (the `#[tokio::main]`
     /// pattern) instead of owning one, and deliver messages while driven by