Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
core.async debounce
(defn debounce [in ms]
(let [out (chan)]
(go-loop [last-val nil]
(let [val (if (nil? last-val) (<! in) last-val)
timer (timeout ms)
[new-val ch] (alts! [in timer])]
(condp = ch
timer (do (>! out val) (recur nil))
in (recur new-val))))
out))
@felixflores

This comment has been minimized.

Copy link

@felixflores felixflores commented Dec 8, 2014

Thanks for this 😃

@aiba

This comment has been minimized.

Copy link

@aiba aiba commented Apr 18, 2016

Nice!

@wilkerlucio

This comment has been minimized.

Copy link

@wilkerlucio wilkerlucio commented Jun 20, 2016

nice, just one comment, this implementation has one issue, that is when you close the in channel it gets into an infinite loop by recurring with new-val as nil all the time, the fix is simple, just check the value when receiving from in:

(defn debounce [in ms]
  (let [out (chan)]
    (go-loop [last-val nil]
      (let [val (if (nil? last-val) (<! in) last-val)
            timer (timeout ms)
            [new-val ch] (alts! [in timer])]
        (condp = ch
          timer (do (>! out val) (recur nil))
          in (if new-val (recur new-val)))))
    out))
@danieldroit

This comment has been minimized.

Copy link

@danieldroit danieldroit commented Apr 3, 2019

closing the in when out gets closed:

(defn debounce [in ms]
  (let [out (chan)]
    (go-loop [last-val nil]
             (let [val   (if (nil? last-val) (<! in) last-val)
                   timer (timeout ms)
                   [new-val ch] (alts! [in timer])]
               (condp = ch
                 timer (do (when-not
                             (>! out val)
                             (close! in))
                           (recur nil))
                 in (if new-val (recur new-val)))))
    out))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.