db.clj

(defn customers [db] 
  (let [ch (chan 100)
        db-ch (exec-customer-query db :all)]
      (go-loop []
               (when-let [customer (<! db-ch)]
                         (>! ch customer)
                         (recur)))
      ch))