diff options
| author | littleblack111 <littleblack11111@gmail.com> | 2025-09-21 23:08:48 +0800 |
|---|---|---|
| committer | littleblack111 <littleblack11111@gmail.com> | 2025-09-21 23:08:48 +0800 |
| commit | 0cfc9d0f4acac43ce20b445ac883b7cf0ca1dc79 (patch) | |
| tree | 14a465146b8858f1f46b6a4552604adfe1328b9e /src/client/connector.rs | |
| parent | 8cdda8a10c563b3d6e6e306c421583f1ade3e6c1 (diff) | |
format
Diffstat (limited to 'src/client/connector.rs')
| -rw-r--r-- | src/client/connector.rs | 40 |
1 files changed, 33 insertions, 7 deletions
diff --git a/src/client/connector.rs b/src/client/connector.rs index d977ace..25f8b5c 100644 --- a/src/client/connector.rs +++ b/src/client/connector.rs @@ -27,18 +27,23 @@ pub trait Connection { fn get_ip(&self) -> Option<IpAddr>; fn force_network(&mut self) { - _ = Executor::new(&NETWORK_T, ["true"]); + _ = Executor::new( + &NETWORK_T, + ["true"], + ); } fn init<'a>(&self, c: &Client<'a, Self>) -> std::result::Result<(), Self::Err> where Self: std::marker::Sized, { - self.ntfy(format!( - r#"New client: + self.ntfy( + format!( + r#"New client: {c} "#, - )) + ), + ) } fn reinit(&mut self) { @@ -60,17 +65,38 @@ pub trait Connection { return; } - let mut it = s.as_ref().split_whitespace(); + let mut it = s + .as_ref() + .split_whitespace(); let task = match it.next() { Some(t) => t, None => return, }; // FIXME: handle the errors... peak prod code - self.ntfy(Executor::new(task.try_into().unwrap(), it).unwrap().run().unwrap().clone().unwrap()).unwrap(); + self.ntfy( + Executor::new( + task.try_into() + .unwrap(), + it, + ) + .unwrap() + .run() + .unwrap() + .clone() + .unwrap(), + ) + .unwrap(); } Result::Err(e) => { #[cfg(debug_assertions)] - std::eprintln!("[{}:{}:{}] {} = {:#?}", std::file!(), std::line!(), std::column!(), std::stringify!(e), &&e as &dyn std::fmt::Debug,); + std::eprintln!( + "[{}:{}:{}] {} = {:#?}", + std::file!(), + std::line!(), + std::column!(), + std::stringify!(e), + &&e as &dyn std::fmt::Debug, + ); } } } |
