Filter asynchronous events (#466)

esp-rs · Aug 5, 2024 · bf47d2b · bf47d2b
1 parent 35e59fa
commit bf47d2b
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/eventloop.rs b/src/eventloop.rs
@@ -441,12 +441,16 @@ where
             self.given = false;
         }
 
-        if let Some(data) = self.receiver.get_shared_async().await {
+        while let Some(data) = self.receiver.get_shared_async().await {
+            if Some(data.source) != D::source() {
+                self.receiver.done();
+                continue;
+            }
             self.given = true;
-            Ok(D::deserialize(data))
-        } else {
-            Err(EspError::from_infallible::<ESP_ERR_INVALID_STATE>())
+            return Ok(D::deserialize(data));
         }
+
+        Err(EspError::from_infallible::<ESP_ERR_INVALID_STATE>())
     }
 }