(def worker
  (go-loop []
    (let [job (<! queue)]
      (println job)
      (job) ;; here throw exception
      (if (nil? job)
        (println "queue finished")
        (recur)))))

;; so now add job for worker
(add-job #(throw (ex-info "foo" {:test 1})))

;; this will break go-loop and worker gone. How to avoid it? Only try and catch? Better pattern?