gszeliga · December 3, 2017 17:46
diff --git a/javaadvent_core_async_readfile.clj b/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))
	(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))