async loop macro

gistfile1.clj

(defmacro defstate [name state & inputs]
  (let [[sym init] state
        pairs (mapv vec (partition 2 inputs))
        in (gensym)
        dispatch (fn [i [f r]] 
                   (~'or (~'and (~'fn? f) 
                                (f i))
                         (~'= f i) 
                         r))]
    `(do
       (~'def ~name (~'chan (async/sliding-buffer 1)))
       (~'go 
        (~'loop [~sym ~init]
                (~'prn ~sym)
                (~'let [~in (~'<! ~name)] 
                       
                       (~'recur
                        (~'last
                         (~'first 
                          (~'filter
                           (~'fn [[~'i ~'r]] 
                                 (~'or 
                                  (~'and (~'fn? ~'i) 
                                         (~'i ~in))
                                  (~'= ~'i ~in)))  
                           ~pairs)))
                        )))))))