gistfile1.txt

(let [par (atom 0)]
  (core/add-watch par
                  :meh
                  (fn [_k _r _o n]
                    (prn :par n)))
  (pipeline 2
            (chan (dropping-buffer 1))
            (core/map (fn [i]
                   (swap! par inc)
                   (Thread/sleep (rand-int 100))
                   (swap! par dec)
                   i))
            (to-chan! (range 50))))