                     #(test-var results tvar))))
               (recur))
             (do
-              (deliver (nth finished worker-id) 1)))))
+              (deliver (nth finished worker-id) t/*report-counters*)))))
       (catch Throwable e
         (.printStackTrace e))
       (finally (deliver (nth finished worker-id) 1)))))

(defn run-worker [results tests-to-run worker-id finished]
  (future
    (try
      (binding [*result-queue* results]
        (loop []
          (if-let [[tvar each-fixture once-fixture] (.poll tests-to-run)]
            (do

    (doseq [n finished]
      (deref n))
    (doseq [r (iterator-seq (.iterator results))]
      (println r))
    (apply merge-with + (map (comp deref deref) finished))))

(defn gather-tests [ns-re]
  (let [queue (LinkedBlockingQueue.)]
