 
 
 (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)))
+  "Apply the handler to the given values"
+  [handler values]
+  (handler values))
 
 
 

    component/Lifecycle


  (start [{done :route config :config :as this}]
    (if-not done
      (-> this
          (assoc :route (build-routes this))
          (assoc :global-stores    (atom {}))
          (assoc :output-collector (atom nil)))
      this))


  (stop [{done :route :as this}]
    (if done
      (-> this
          (assoc :route            nil)
          (assoc :global-stores    nil)
          (assoc :output-collector nil))
      this)))






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