javaadvent_core_async_readfile.clj

(defn stream-lines-from [path]                                                                                                                                                                 
  (let [c (chan 1024)]                                                                                                                                                                         
    (go                                                                                                                                                                                        
      (with-open [rdr (io/reader path)]                                                                                                                                                        
        (doseq [line (line-seq rdr)]                                                                                                                                                           
          (>! c line)))                                                                                                                                                                        
      (close! c))                                                                                                                                                                              
    c))