                   (not (nil? in-data))
                   (not (nil? pipeline))) (create-flood-in-fn (get-in-fn pipeline))
                 :default (if (not (.contains scenario "async-pipeline"))
-                           (fn [] (.inc out-cntr))))]
+                           out-fn))]
     in-fn))
 
 (defn -main [& args]

    (println "Using args:" arguments)
    (let [in-cntr (Counter.)
          out-cntr (Counter.)
          delta-cntr (delta-counter)
          ^String scenario (:scenario options)
          in-data (prepare-in-data options)

    proc-fns))

(defn prepare-in-fn
  [options scenario in-data ^Counter in-cntr out-fn in-chan pipeline queue-size]
  (let [batch-delay (:batch-delay options)
        batch-size (:batch-size options)
        create-batched-in-fn (fn [in-fn]
