Quantisan

(require '[clojure.core.async :as async]
         '[clojure.core.async.flow :as flow]
         '[clojure.pprint :as pp])

;; Monitoring function to show the built-in reporting and error handling
;; This showcases the centralized monitoring capabilities of the flow system
(defn monitoring [{:keys [report-chan error-chan]}]
  (prn "========= monitoring start")
  (async/thread
    (loop []