summaryrefslogtreecommitdiff
path: root/src/client/connector.rs
diff options
context:
space:
mode:
authorlittleblack111 <littleblack11111@gmail.com>2025-09-21 23:08:41 +0800
committerlittleblack111 <littleblack11111@gmail.com>2025-09-21 23:08:41 +0800
commit22c98311a8e8f4a1c94b0e4ac0f36b4e016a2bf4 (patch)
tree6453e6991b39e05bda169bd13ceb4cf0f2ccecbd /src/client/connector.rs
parent2e1d12ec90ea12e8824d79dfc31b5b3cae397df8 (diff)
format
Diffstat (limited to 'src/client/connector.rs')
-rw-r--r--src/client/connector.rs42
1 files changed, 35 insertions, 7 deletions
diff --git a/src/client/connector.rs b/src/client/connector.rs
index 22a9f5a..c1a5f7f 100644
--- a/src/client/connector.rs
+++ b/src/client/connector.rs
@@ -34,18 +34,24 @@ pub trait Connection {
fn get_ip(&self) -> Option<IpAddr>;
fn force_network(&mut self) {
- _ = Executor::new(NETWORK_T.as_ref(), ["true"], ());
+ _ = Executor::new(
+ NETWORK_T.as_ref(),
+ ["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) {
@@ -67,17 +73,39 @@ 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() as result::Result<Task, IntoTaskErr>).unwrap().as_ref(), it, ()).run().as_ref().unwrap().clone()).unwrap();
+ self.ntfy(
+ Executor::new(
+ (task.try_into() as result::Result<Task, IntoTaskErr>)
+ .unwrap()
+ .as_ref(),
+ it,
+ (),
+ )
+ .run()
+ .as_ref()
+ .unwrap()
+ .clone(),
+ )
+ .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,
+ );
}
}
}