Merge pull request #27 from grapp-dev/feature/add-new-operators

feat: add `debounce` and `start_with` operators

Author: mobily

docs/pages/docs/signal.mdx

@@ -224,6 +224,18 @@ And here's the final result:
 
 <Method name="negate" returns="SignalValue" />
 
+#### debounce
+
+> Delays an operation until a specified time has passed without further input.
+
+<Method 
+  name="debounce" 
+  args={[
+    ['ms', 'number'],
+  ]}
+  returns="SignalValue" 
+/>
+
 #### tap
 
 > Executes a function with each value emitted by the observable.
@@ -286,6 +298,18 @@ And here's the final result:
   returns="SignalValue" 
 />
 
+#### start_with
+
+> Emits a default value immediately and synchronously after subscribing.
+
+<Method 
+  name="start_with" 
+  args={[
+    ['default_value', 'T'],
+  ]}
+  returns="SignalValue" 
+/>
+
 #### observe
 
 > Subscribes an observer function to the observable. The observer function is called every time a new value is emitted by the observable.

lua/nui-components/rx/init.lua

@@ -12,5 +12,6 @@ require("nui-components.rx.operators.scan")
 require("nui-components.rx.operators.skip")
 require("nui-components.rx.operators.combine_latest")
 require("nui-components.rx.operators.debounce")
+require("nui-components.rx.operators.start_with")
 
 return Rx

lua/nui-components/rx/operators/start_with.lua

@@ -0,0 +1,11 @@
+local Observable = require("nui-components.rx.observable")
+local fn = require("nui-components.utils.fn")
+
+function Observable:start_with(...)
+  local values = fn.pack(...)
+
+  return Observable.create(function(observer)
+    observer:on_next(fn.unpack(values))
+    return self:subscribe(observer)
+  end)
+end

lua/nui-components/signal/value.lua

@@ -58,6 +58,16 @@ function SignalValue:skip(n)
   return self
 end
 
+function SignalValue:debounce(ms)
+  self._private.observable = self._private.observable:debounce(ms)
+  return self
+end
+
+function SignalValue:start_with(value)
+  self._private.observable = self._private.observable:start_with(value)
+  return self
+end
+
 function SignalValue:combine_latest(...)
   local signal_values = { ... }