Fix the lock release in asynchronous

stainless-steel · Dec 28, 2024 · 2c8808a · 2c8808a
1 parent 28f4226
commit 2c8808a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "loop"
-version = "0.5.1"
+version = "0.5.2"
 edition = "2021"
 license = "Apache-2.0/MIT"
 authors = ["Ivan Ukhov <ivan.ukhov@gmail.com>"]

diff --git a/src/asynchronous.rs b/src/asynchronous.rs
@@ -27,7 +27,10 @@ where
         let item_receiver = item_receiver.clone();
         let output_sender = output_sender.clone();
         std::mem::drop(tokio::task::spawn(async move {
-            while let Some(item) = item_receiver.lock().await.recv().await {
+            while let Some(item) = {
+                let mut receiver = item_receiver.lock().await;
+                receiver.recv().await
+            } {
                 if output_sender.send(map(item).await).await.is_err() {
                     break;
                 }