chore: fmt

Author: Karrq

msg-socket/src/hooks/mod.rs

@@ -16,7 +16,7 @@
 //!
 //! ```no_run
 //! use msg_socket::hooks::{ConnectionHook, Error, HookResult};
-//! use tokio::io::{AsyncRead, AsyncWrite, AsyncReadExt, AsyncWriteExt};
+//! use tokio::io::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt};
 //!
 //! struct MyAuth;
 //!
@@ -143,7 +143,9 @@ where
         Box::pin(async move {
             ConnectionHook::on_connection(&*self, io).await.map_err(|e| match e {
                 Error::Io(io_err) => Error::Io(io_err),
-                Error::Hook(hook_err) => Error::Hook(Box::new(hook_err) as Box<dyn StdError + Send + Sync>),
+                Error::Hook(hook_err) => {
+                    Error::Hook(Box::new(hook_err) as Box<dyn StdError + Send + Sync>)
+                }
             })
         })
     }

msg-socket/src/hooks/token.rs

@@ -8,21 +8,22 @@
 //! # Example
 //!
 //! ```no_run
-//! use msg_socket::{RepSocket, ReqSocket};
-//! use msg_socket::hooks::token::{ServerHook, ClientHook};
-//! use msg_transport::tcp::Tcp;
 //! use bytes::Bytes;
+//! use msg_socket::{
+//!     RepSocket, ReqSocket,
+//!     hooks::token::{ClientHook, ServerHook},
+//! };
+//! use msg_transport::tcp::Tcp;
 //!
 //! // Server side - validates incoming tokens
-//! let rep = RepSocket::new(Tcp::default())
-//!     .with_connection_hook(ServerHook::new(|token| {
-//!         // Custom validation logic
-//!         token == b"secret"
-//!     }));
+//! let rep = RepSocket::new(Tcp::default()).with_connection_hook(ServerHook::new(|token| {
+//!     // Custom validation logic
+//!     token == b"secret"
+//! }));
 //!
 //! // Client side - sends token on connect
-//! let req = ReqSocket::new(Tcp::default())
-//!     .with_connection_hook(ClientHook::new(Bytes::from("secret")));
+//! let req =
+//!     ReqSocket::new(Tcp::default()).with_connection_hook(ClientHook::new(Bytes::from("secret")));
 //! ```
 
 use std::io;
@@ -147,8 +148,8 @@ where
 /// # Example
 ///
 /// ```no_run
-/// use msg_socket::hooks::token::ClientHook;
 /// use bytes::Bytes;
+/// use msg_socket::hooks::token::ClientHook;
 ///
 /// let hook = ClientHook::new(Bytes::from("my_secret_token"));
 /// ```

msg-socket/src/pub/driver.rs

@@ -5,9 +5,9 @@ use std::{
 };
 
 use futures::{Future, StreamExt, stream::FuturesUnordered};
+use msg_common::span::{EnterSpan as _, SpanExt as _, WithSpan};
 use tokio::{sync::broadcast, task::JoinSet};
 use tokio_util::codec::Framed;
-use msg_common::span::{EnterSpan as _, SpanExt as _, WithSpan};
 use tracing::{debug, error, info, warn};
 
 use super::{

msg-socket/src/req/conn_manager.rs

@@ -27,7 +27,9 @@ pub(crate) enum ConnectionError<T: std::error::Error> {
 
 impl<T: std::error::Error + From<std::io::Error>> ConnectionError<T> {
     /// Create a ConnectionError from an erased hook error, converting Io errors to Transport.
-    pub(crate) fn from_erased_hook(err: hooks::Error<Box<dyn std::error::Error + Send + Sync>>) -> Self {
+    pub(crate) fn from_erased_hook(
+        err: hooks::Error<Box<dyn std::error::Error + Send + Sync>>,
+    ) -> Self {
         match err {
             hooks::Error::Io(io_err) => Self::Transport(T::from(io_err)),
             hooks::Error::Hook(e) => Self::Hook(e),

msg-socket/src/sub/driver.rs

@@ -6,10 +6,13 @@ use std::{
 };
 
 use futures::{Future, StreamExt};
+use msg_common::span::{EnterSpan as _, SpanExt as _, WithSpan};
 use rustc_hash::FxHashMap;
-use tokio::{sync::mpsc::{self, error::TrySendError}, task::JoinSet};
+use tokio::{
+    sync::mpsc::{self, error::TrySendError},
+    task::JoinSet,
+};
 use tokio_util::codec::Framed;
-use msg_common::span::{EnterSpan as _, SpanExt as _, WithSpan};
 use tracing::{debug, error, info, warn};
 
 use super::{