summaryrefslogtreecommitdiff
path: root/src/client/connector.rs
diff options
context:
space:
mode:
authorlittleblack111 <littleblack11111@gmail.com>2025-09-21 23:08:48 +0800
committerlittleblack111 <littleblack11111@gmail.com>2025-09-21 23:08:48 +0800
commit0cfc9d0f4acac43ce20b445ac883b7cf0ca1dc79 (patch)
tree14a465146b8858f1f46b6a4552604adfe1328b9e /src/client/connector.rs
parent8cdda8a10c563b3d6e6e306c421583f1ade3e6c1 (diff)
format
Diffstat (limited to 'src/client/connector.rs')
-rw-r--r--src/client/connector.rs40
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,
+ );
}
}
}