summaryrefslogtreecommitdiff
path: root/src/main.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/main.rs')
-rw-r--r--src/main.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/main.rs b/src/main.rs
index 88e5a33..7d609c2 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -8,8 +8,8 @@ use std::collections::HashMap;
use std::fs;
use std::process;
use std::sync::Arc;
+use std::sync::Mutex;
use std::time::Duration;
-use tokio::sync::Mutex;
use tokio::task::{Id, JoinSet};
use tracing::{debug, error, info, warn};
@@ -119,7 +119,7 @@ async fn fetch_prusa(
.await?
.json::<PrusaStatus>()
.await?;
- let mut lock = state.lock().await;
+ let mut lock = state.lock().unwrap();
lock.entry(name.to_owned())
.or_default()
.update_from(&response);
@@ -203,7 +203,7 @@ async fn poll_bambu(
debug!(payload = ?p.payload, "Received Bambu payload");
match serde_json::from_slice::<BambuStatus>(&p.payload) {
Ok(msg) => {
- let mut lock = state.lock().await;
+ let mut lock = state.lock().unwrap();
lock.entry(name.clone()).or_default().update_from(&msg);
debug!(name, payload = ?p.payload, "Updated state");
}
@@ -220,5 +220,5 @@ async fn poll_bambu(
}
async fn root(State(state): State<StateMap>) -> Json<HashMap<String, PrinterState>> {
- Json(state.lock().await.clone())
+ Json(state.lock().unwrap().clone())
}