fix: gracefully handle lock reading

breez · Jan 20, 2025 · cd3658b · cd3658b
1 parent 847a8df
commit cd3658b
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/lib/core/src/persist/sync.rs b/lib/core/src/persist/sync.rs
@@ -249,7 +249,7 @@ impl Persister {
         record_type: RecordType,
         updated_fields: Option<Vec<String>>,
     ) -> Result<()> {
-        if self.sync_trigger.read().unwrap().is_none() {
+        if self.sync_trigger.try_read().is_ok_and(|t| t.is_none()) {
             return Ok(());
         }
 
@@ -499,8 +499,10 @@ impl Persister {
     }
 
     pub(crate) fn trigger_sync(&self) -> Result<()> {
-        if let Some(trigger) = self.sync_trigger.read().unwrap().deref() {
-            return Ok(trigger.try_send(())?);
+        if let Ok(lock) = self.sync_trigger.try_read() {
+            if let Some(trigger) = lock.clone() {
+                trigger.try_send(())?;
+            }
         }
         Ok(())
     }