chore: fmt

Author: merklefruit

msg-socket/src/rep/mod.rs

@@ -247,7 +247,8 @@ mod tests {
     #[tokio::test(flavor = "multi_thread", worker_threads = 4)]
     async fn rep_max_connections() {
         let _ = tracing_subscriber::fmt::try_init();
-        let mut rep = RepSocket::with_options(Tcp::default(), RepOptions::default().with_max_clients(1));
+        let mut rep =
+            RepSocket::with_options(Tcp::default(), RepOptions::default().with_max_clients(1));
         rep.bind("127.0.0.1:0").await.unwrap();
         let addr = rep.local_addr().unwrap();
 
@@ -264,15 +265,19 @@ mod tests {
 
     #[tokio::test(flavor = "multi_thread", worker_threads = 4)]
     async fn test_basic_reqrep_with_compression() {
-        let mut rep =
-            RepSocket::with_options(Tcp::default(), RepOptions::default().with_min_compress_size(0))
-                .with_compressor(SnappyCompressor);
+        let mut rep = RepSocket::with_options(
+            Tcp::default(),
+            RepOptions::default().with_min_compress_size(0),
+        )
+        .with_compressor(SnappyCompressor);
 
         rep.bind("0.0.0.0:4445").await.unwrap();
 
-        let mut req =
-            ReqSocket::with_options(Tcp::default(), ReqOptions::default().with_min_compress_size(0))
-                .with_compressor(GzipCompressor::new(6));
+        let mut req = ReqSocket::with_options(
+            Tcp::default(),
+            ReqOptions::default().with_min_compress_size(0),
+        )
+        .with_compressor(GzipCompressor::new(6));
 
         req.connect("0.0.0.0:4445").await.unwrap();
 

msg/examples/durable.rs

@@ -61,7 +61,9 @@ async fn main() {
     // and an identifier. This will implicitly turn on client authentication.
     let mut req = ReqSocket::with_options(
         Tcp::default(),
-        ReqOptions::default().with_timeout(Duration::from_secs(4)).with_auth_token(Bytes::from("client1")),
+        ReqOptions::default()
+            .with_timeout(Duration::from_secs(4))
+            .with_auth_token(Bytes::from("client1")),
     );
 
     let (tx, rx) = oneshot::channel();

msg/examples/pubsub.rs

@@ -19,8 +19,10 @@ async fn main() {
     );
 
     // Configure the subscribers with options
-    let mut sub1 =
-        SubSocket::with_options(Tcp::default(), SubOptions::default().with_ingress_buffer_size(1024));
+    let mut sub1 = SubSocket::with_options(
+        Tcp::default(),
+        SubOptions::default().with_ingress_buffer_size(1024),
+    );
 
     let mut sub2 = SubSocket::with_options(
         // TCP transport with blocking connect, usually connection happens in the background.

msg/examples/quic_vs_tcp.rs

@@ -25,8 +25,10 @@ async fn run_tcp() {
     );
 
     // Configure the subscribers with options
-    let mut sub1 =
-        SubSocket::with_options(Tcp::default(), SubOptions::default().with_ingress_buffer_size(1024));
+    let mut sub1 = SubSocket::with_options(
+        Tcp::default(),
+        SubOptions::default().with_ingress_buffer_size(1024),
+    );
 
     tracing::info!("Setting up the sockets...");
     pub_socket.bind("127.0.0.1:0").await.unwrap();