           (deliver (get stop-here :c) true)
           (is (= [:done :c] (async/<!! out-chan)))
 
-          (is (not= ::timed-out (deref fut 1000 ::timed-out)))
+          (is (not= ::timed-out (deref fut tu/default-timeout-ms ::timed-out)))
           (is (true? (future-done? fut))))))))
 
 

                    (dochan gtp worker-fn in-chan))]

          (async/>!! in-chan {:id :a})
          (is (= true (deref (:a in-flight-promises) 100 ::not-found)))

          (async/>!! in-chan {:id :b})
          (is (= true (deref (:b in-flight-promises) 100 ::not-found)))

          (async/>!! in-chan {:id :c})
          (async/close! in-chan)

          (deliver (get stop-here :a) true)

          (is (= [:done :a] (async/<!! out-chan)))
          (is (= true (deref (:c in-flight-promises) tu/default-timeout-ms ::not-found)))
          (is (= [:a :b :c] @seen))

          (deliver (get stop-here :b) true)
