Skip to content

Instantly share code, notes, and snippets.

;;=============== play with flow ==============
(require '[clojure.core.async :as async]
'[clojure.core.async.flow :as flow]
'[clojure.pprint :as pp]
'[clojure.datafy :as d]
'[clojure.walk :as w])
(set! *warn-on-reflection* true)
(defn monitoring [{:keys [report-chan error-chan]}]