Clojure core.async exception handling

gistfile1.clj

(defn nil->keyword [x] (if (nil? x) :nil x))

(defn nil-safe [f] (comp nil->keyword f))

(defn lift
  [f]
  (fn [x]
      (cond
        (instance? Throwable x) x
        (nil? x)                :nil
        (= :nil x)              :nil
        :default                (try ((nil-safe f) x)
                                     (catch Throwable t t)))))

(defn log-throwable [t] (if (instance? Throwable t) (prn "got: " t)) t)

(def input (chan))

(->> input
     (async/map< (lift #(/ 5 %)))
     (async/map< (lift prn))
     (async/map< log-throwable)
     (suck))

(async/put! input 0)