Make rustfmt happy

ferrous-systems · May 23, 2024 · 23e7add · 23e7add
1 parent 6f69d4f
commit 23e7add
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 11 deletions.
diff --git a/exercise-solutions/async-chat/src/client.rs b/exercise-solutions/async-chat/src/client.rs
@@ -1,5 +1,5 @@
 use tokio::{
-    io::{stdin, BufReader, AsyncBufReadExt, AsyncWriteExt},
+    io::{stdin, AsyncBufReadExt, AsyncWriteExt, BufReader},
     net::{TcpStream, ToSocketAddrs},
 };
 
@@ -38,4 +38,4 @@ async fn try_main(addr: impl ToSocketAddrs) -> Result<()> {
         }
     }
     Ok(())
-}
+}
diff --git a/exercise-solutions/async-chat/src/main.rs b/exercise-solutions/async-chat/src/main.rs
@@ -10,4 +10,4 @@ fn main() -> Result<()> {
         (Some("server"), None) => server::main(),
         _ => Err("Usage: a-chat [client|server]".into()),
     }
-}
+}
diff --git a/exercise-solutions/async-chat/src/server.rs b/exercise-solutions/async-chat/src/server.rs
@@ -1,15 +1,15 @@
 use std::{
     collections::hash_map::{Entry, HashMap},
-    sync::Arc,
     future::Future,
+    sync::Arc,
 };
 
 use tokio::sync::mpsc;
 
 use tokio::{
-    io::{BufReader,AsyncWriteExt, AsyncBufReadExt},
-    net::{TcpListener, TcpStream, ToSocketAddrs},
+    io::{AsyncBufReadExt, AsyncWriteExt, BufReader},
     net::tcp::{OwnedReadHalf, OwnedWriteHalf},
+    net::{TcpListener, TcpStream, ToSocketAddrs},
     task,
 };
 
@@ -159,10 +159,9 @@ async fn broker_loop(mut events: Receiver<Event>) {
                     let mut disconnect_sender = disconnect_sender.clone();
                     spawn_and_log_error(async move {
                         let res =
-                            connection_writer_loop(&mut client_receiver, &mut stream, shutdown).await;
-                        disconnect_sender
-                            .send((name, client_receiver))
-                            .unwrap();
+                            connection_writer_loop(&mut client_receiver, &mut stream, shutdown)
+                                .await;
+                        disconnect_sender.send((name, client_receiver)).unwrap();
                         res
                     });
                 }
@@ -183,4 +182,4 @@ where
             eprintln!("{}", e)
         }
     })
-}
+}