Add calm!

cmeiklejohn · Mar 13, 2013 · deaf858 · deaf858
1 parent 89fae58
commit deaf858
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/README.md b/README.md
@@ -47,7 +47,7 @@ switchE         |                   | calmB        |
 delayE          | delay!
 snapshotE       | snapshot!
 filterRepeatsE  | filter-repeats!
-calmE           |
+calmE           | calm!
 blindE          |
 timerE          | timer!
 

diff --git a/src/cljs/shafty/core.cljs b/src/cljs/shafty/core.cljs
@@ -68,6 +68,7 @@
   (bind! [this value-fn])
   (once! [this])
   (delay! [this interval])
+  (calm! [this interval])
   (merge! [this that])
   (filter! [this filter-fn])
   (collect! [this init combine-fn])
@@ -176,6 +177,16 @@
           e (event [this] f)]
       (add-sink! this e) e))
 
+  (calm! [this interval]
+    (let [acc (atom nil)
+          t (atom nil)
+          f (fn [me x]
+              (swap! acc (fn [] x))
+              (if (nil? t)
+                (js/setTimeout (fn []
+                                 (swap! t (fn [] nil))
+                                 (.-value acc)) interval)))
+          e (event [this] f)]
       (add-sink! this e) e))
 
   (merge! [this that]