     (println "Using options:" options)
     (println "Using args:" arguments)
     (let [in-cntr (Counter.)
+          pre-in-fn (if (:latency options)
+                      (do
+                        (println "Creating latency measurement pre-in-fn.")
+                        (fn [in-obj]
+                          (.inc in-cntr)
+                          (LatencyProbe. in-obj)))
+                      (do
+                        (println "Creating default measurement pre-in-fn.")
+                        (fn [in-obj]
+                          (.inc in-cntr)
+                          in-obj)))
           out-cntr (Counter.)
           latency-probe-collector (LatencyProbeCollector.)
           out-fn (if (:latency options)

                    (async/chan queue-size))
          out-chan (if (.contains scenario "async-pipeline")
                     (async/chan queue-size))
          in-fn (prepare-in-fn options scenario in-data in-cntr out-fn in-chan pipeline queue-size)
          in-loop (ProcessingLoop.
                    "DataGenerationLoop"
                    in-fn)

          (println "Starting async-pipeline-go input creation.")
          (async/go
            (loop []
              (async/>! in-chan (pre-in-fn in-data))
              (recur)))
          (sleep 130000))
        (do
