RosettaCodeData/Task/Synchronous-concurrency/Clojure/synchronous-concurrency-2.clj

7 lines
172 B
Clojure

(with-open [r (io/reader "input.txt")]
(doseq [line (line-seq r)]
(send writer write-line line)))
(await writer)
(println "lines written:" @writer)
(shutdown-agents)