From 60e1ebb503b98d683270755257f355bb499d12ae Mon Sep 17 00:00:00 2001 From: hommeabeil Date: Wed, 2 Feb 2022 22:11:32 -0500 Subject: [PATCH] fmt --- actix-server/src/accept.rs | 2 +- actix-server/src/socket.rs | 15 ++++++--------- 2 files changed, 7 insertions(+), 10 deletions(-) diff --git a/actix-server/src/accept.rs b/actix-server/src/accept.rs index 0602343a..664728fd 100644 --- a/actix-server/src/accept.rs +++ b/actix-server/src/accept.rs @@ -332,7 +332,7 @@ impl Accept { .for_each(|(_, info)| self.deregister_logged(info)); } - fn terminate_all(&self, sockets: &mut[ServerSocketInfo]) { + fn terminate_all(&self, sockets: &mut [ServerSocketInfo]) { sockets.iter().for_each(|s| s.lst.terminate()); } diff --git a/actix-server/src/socket.rs b/actix-server/src/socket.rs index e5a711d0..adb165b8 100644 --- a/actix-server/src/socket.rs +++ b/actix-server/src/socket.rs @@ -38,9 +38,7 @@ impl MioListener { match *self { MioListener::Tcp(ref lst) => lst.accept().map(|(stream, _)| MioStream::Tcp(stream)), #[cfg(unix)] - MioListener::Uds(ref lst) => { - lst.accept().map(|(stream, _)| MioStream::Uds(stream)) - } + MioListener::Uds(ref lst) => lst.accept().map(|(stream, _)| MioStream::Uds(stream)), } } @@ -49,17 +47,16 @@ impl MioListener { MioListener::Tcp(_) => (), #[cfg(unix)] MioListener::Uds(ref lst) => { - if let Ok(addr) = lst.local_addr() { - if let Some(path) = addr.as_pathname() { - let _ = std::fs::remove_file(path); - } + if let Ok(addr) = lst.local_addr() { + if let Some(path) = addr.as_pathname() { + let _ = std::fs::remove_file(path); } } + } } } } - impl Source for MioListener { fn register( &mut self, @@ -91,7 +88,7 @@ impl Source for MioListener { match *self { MioListener::Tcp(ref mut lst) => lst.deregister(registry), #[cfg(unix)] - MioListener::Uds(ref mut lst) => lst.deregister(registry) + MioListener::Uds(ref mut lst) => lst.deregister(registry), } } }