               pool
               [i input]
               (work i)))]
-    (check-all "pfor" pmap-like true)
+    (check-all "pfor" pmap-like true true)
     (testing "pfor reads lazily"
       (check-lazy-read pmap-like))))
 

  (testing "basic upmap test"
    (cp/with-shutdown! [pool 3]
      (is (= (range 1 11) (sort (cp/upmap pool inc (range 10)))))))
  (check-all "upmap" cp/upmap false)
  (testing "upmap reads lazily"
    (check-lazy-read cp/upmap)))


            second-inputs (range n (* n 2))
            ;; The input will have a pause after n items.
            pause (promise)
            input (concat first-inputs (lazy-seq (list @pause)) second-inputs)
            ;; We'll record what tasks have been started so we can make sure
            ;; all of them are started.
            started (atom #{})
