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


          (is (= [:done 1] (async/<!! out-chan)))

          (is (not= ::timed-out (deref fut 1000 ::timed-out)))
          (is (true? (future-done? fut)))))))

  (testing "blocking put on gated threadpool"

          (is (= [:done :a] (async/<!! out-chan)))
          (is (= 1 @counter))
          (async/close! in-chan)
          (is (not= ::timed-out (deref fut tu/default-timeout-ms ::timed-out)))
          (is (true? (future-done? fut)))))))

  (testing "message in-flight shutdown"
