Don't block async future when enumerating stones

serpent-os · Nov 19, 2024 · 5601413 · 5601413
1 parent 5e33c59
commit 5601413
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/crates/vessel/src/worker.rs b/crates/vessel/src/worker.rs
@@ -129,7 +129,11 @@ async fn handle_message(state: &State, message: Message) -> Result<()> {
             async move {
                 info!("Import started");
 
-                let stones = enumerate_stones(&directory).context("enumerate stones")?;
+                let stones = tokio::task::spawn_blocking(move || enumerate_stones(&directory))
+                    .await
+                    .context("spawn blocking")?
+                    .context("enumerate stones")?;
+
                 let num_stones = stones.len();
 
                 if num_stones > 0 {