async=example.clj

(defn m-dec [buf]
  (io/decode utf-codec buf))

(defn channel-handler [ch]
  (go-loop []
    (try
      (let [ch-data (<! ch) msg (m-dec ch-data)]
        (println "->" msg)
        (if (= msg "stop")
          (throw (Exception. "my exception message"))))
      (catch Exception e (prn "channel exception: " (.getMessage e))
                         (close! ch)
                         (prn "channel shutdown!")))
    (recur)))

(defn channel-new []
  (let [ch (chan)]
    (channel-handler ch) ch))