robot thing

irobot.clj

(defprotocol IRobot ; ha
  (live? [_])
  (kill [_])
  (state [_]))

(defn robot
  ([state f]
   (robot state (constantly true) f))
  ([state continue? f]
   (let [kill (a/chan (a/sliding-buffer 1))
         live (volatile! true)
         state-v (volatile! state)
         rt (a/go-loop []
              (let [state @state-v]
                (if (or (not (continue? state)) (a/poll! kill))
                  (vreset! live false)
                  (do (vreset! state-v (f state))
                      (recur)))))]
     (reify IRobot
       (live? [_] @live)
       (kill [_] (when-not @live (a/go (a/>! kill true) true)))
       (state [_] @state-v)))))