fix: can now publish to the message bus after receiving values from it

podium-lib · Dec 2, 2024 · 2871b1a · 2871b1a
1 parent 59ef7d2
commit 2871b1a
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/store.js b/src/store.js
@@ -129,6 +129,10 @@ export function map(channel, topic, initialValue) {
         // To avoid an infinite loop we fire this only when the source of the change is the app, not the message bus.
         if (source !== 'bus') {
             messageBus.publish(channel, topic, value);
+        } else {
+            // We got this change from the message bus.
+            // Revert to assuming we publish changes now that we're done writing.
+            source = 'app';
         }
     });
 
@@ -181,6 +185,10 @@ export function deepMap(channel, topic, initialValue) {
         // To avoid an infinite loop we fire this only when the source of the change is the app, not the message bus.
         if (source !== 'bus') {
             messageBus.publish(channel, topic, value);
+        } else {
+            // We got this change from the message bus.
+            // Revert to assuming we publish changes now that we're done writing.
+            source = 'app';
         }
     });