 
 
 
-(defn- normalize-streams-with-defaults
+(defn normalize-streams-with-defaults
   "apply streams defaults"
   [config]
   (-> config



(defn process
  "Returns a function which takes a collection of values
   and it applies the given handler to the values as a whole"
  [handler]
  (fn [values]
    (handler values)))




;;                                                                            ;;
;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;

(def ^:dynamic *print-streams*  false)

(defmacro printf-stream [& args]
  `(when *print-streams*
     (printf ~@args)))


(def all-events-counter
  "return a function which is a counter
