file-counter.clj

(ns file-counter.core
  (:require [clojure.core.async :refer :all])
  (:gen-class))

(defn count-files [count-chn path-chn path]
  (doseq [file (.listFiles (java.io.File. path))]
    (if (.isFile file)
      (println (.getAbsolutePath file))
      (>!! path-chn (.getAbsolutePath file)))))

(defn run [path]
 (let [count-chn (chan) path-chn (chan)]

  (go
   (while true
     (let [path (<! path-chn)]
       (go (count-files count-chn path-chn path)))))

  (>!! path-chn path)
   
  (<!! (timeout 10000))))

(run "/tmp")

(defn -main [& args]
  (run "/tmp"))