 
 
 (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))
 
 
 




(def ^:const DEFAULT-STREAM-CFG
  {:input-partitions          :all
   :state                     :none
   :format                    :json
   :processor                 "samsara-core.core/make-samsara-processor"
   :processor-type            :samsara-factory
   :bootstrap                 false
   :output-topic-partition-fn :sourceId})






(defn make-samsara-core [config]
  (map->SamsaraCore {:config config}))



