fix formating

rabbitmq · Feb 14, 2024 · fcbdf56 · fcbdf56
1 parent 7d0139e
commit fcbdf56
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/src/client/dispatcher.rs b/src/client/dispatcher.rs
@@ -1,6 +1,9 @@
 use futures::Stream;
 use rabbitmq_stream_protocol::Response;
-use std::sync::{atomic::{AtomicBool, AtomicU32, Ordering}, Arc};
+use std::sync::{
+    atomic::{AtomicBool, AtomicU32, Ordering},
+    Arc,
+};
 use tracing::trace;
 
 use dashmap::DashMap;
@@ -34,14 +37,14 @@ impl<T> Clone for DispatcherState<T> {
 
 struct RequestsMap {
     requests: DashMap<u32, Sender<Response>>,
-    closed: AtomicBool
+    closed: AtomicBool,
 }
 
 impl RequestsMap {
     fn new() -> RequestsMap {
         RequestsMap {
             requests: DashMap::new(),
-            closed: AtomicBool::new(false)
+            closed: AtomicBool::new(false),
         }
     }