javaadvent_core_async_extract_field.clj

(defn extract-field-fn [fname channel]
  (let [headers   (<!! channel)
        field-idx (->> (split headers  #",") 
                       (map-indexed vector) 
                       (filter (fn [[_ v]] (= v fname))) 
                       first 
                       first)]
    #(java.lang.Double/parseDouble (nth (split % #",") field-idx))))