fix: insert deadlock spacejam#1380

crspecter · Oct 13, 2021 · 34fb986 · 34fb986
1 parent c840fe7
commit 34fb986
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/src/tree.rs b/src/tree.rs
@@ -205,8 +205,19 @@ impl Tree {
         let last_value = last_value.map(IVec::from);
 
         if value == last_value {
+            // NB: always broadcast event
+            if let Some(Some(res)) = subscriber_reservation.take() {
+                let event = subscriber::Event::single_update(
+                    self.clone(),
+                    key.as_ref().into(),
+                    value,
+                );
+
+                res.complete(&event);
+            }
+
             // short-circuit a no-op set or delete
-            return Ok(Ok(value));
+            return Ok(Ok(last_value));
         }
 
         let frag = if let Some(value) = value.clone() {