richhickey

;;=============== play with flow ==============
(require '[clojure.core.async :as async]
         '[clojure.core.async.flow :as flow]
         '[clojure.pprint :as pp]
         '[clojure.datafy :as d])

(set! *warn-on-reflection* true)

(defn monitoring [{:keys [report-chan error-chan]}]
  (prn "========= monitoring start")