                                  (ProcessingLoop.
                                    "AsyncOutputCountLoop"
                                    (fn []
-                                     (async/<!! out-chan)
-                                     (.inc out-cntr))))
+                                     (out-fn (async/<!! out-chan)))))
           async-count-go (when
                            (and
                              (.endsWith scenario "-async-pipeline-go")

                       (not (.contains scenario "async-pipeline")))
                     (create-local-processing-pipeline
                       @proc-fns
                       (fn [_ _]
                         (.inc out-cntr))))
          in-chan (if (.contains scenario "async-pipeline")
                    (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-cntr in-chan pipeline queue-size)
          in-loop (ProcessingLoop.
                    "DataGenerationLoop"
                    in-fn)

                           (println "Starting async-pipeline-go counting.")
                           (async/go
                             (loop []
                               (out-fn (async/<! out-chan))
                               (recur))))
          direct-proc-fn (create-direct-proc-fn scenario)
          async-pipeline (if
