fix: ensure that only the relevant signal value is emitted (part 2)

Author: mobily

lua/nui-components/signal/init.lua

@@ -47,7 +47,7 @@ function Signal.create(object)
     end,
     __newindex = function(t, key, value)
       t[self.__index][key] = value
-      self._private.subject(t[self.__index], key)
+      self._private.subject(t[self.__index])
     end,
   })
 

lua/nui-components/signal/value.lua

@@ -1,3 +1,4 @@
+local Observable = require("nui-components.rx.observable")
 local fn = require("nui-components.utils.fn")
 
 local SignalValue = {}
@@ -10,13 +11,13 @@ function SignalValue.create(subject, key)
     _private = {
       key = key,
       subject = subject,
-      observable = subject
-        :filter(function(_, k)
-          return k == nil or k == key
-        end)
-        :map(function(value)
-          return value[key]
-        end),
+      observable = Observable.defer(function()
+        return subject
+          :map(function(value)
+            return value[key]
+          end)
+          :distinct_until_changed(vim.deep_equal)
+      end),
     },
   }
 
@@ -32,7 +33,7 @@ function SignalValue:get_observer_value()
 end
 
 function SignalValue:get_observable()
-  return self._private.observable:distinct_until_changed(vim.deep_equal)
+  return self._private.observable
 end
 
 function SignalValue:map(map_fn)