                                            "x-waiter-timeout" "1000")]
                              (websocket/add-headers-to-upgrade-request! request headers))
                            (add-auth-cookie request auth-cookie-value))})
-          (is (= :done (deref response-promise (-> 2 t/minutes t/in-millis) :timed-out))))
+          (is (= :done (deref response-promise default-timeout-period :timed-out))))
         (is (not @send-success-after-timeout-atom))
         (finally
           (delete-service waiter-url waiter-headers))))))

            {:middleware (fn [_ ^UpgradeRequest request]
                           (websocket/add-headers-to-upgrade-request! request waiter-headers)
                           (add-auth-cookie request auth-cookie-value))})
          (is (= :done (deref response-promise (-> 2 t/minutes t/in-millis) :timed-out))))
        (is @uncorrupted-data-streamed-atom)
        (finally
          (delete-service waiter-url waiter-headers))))))

            (request-streaming-helper waiter-url waiter-headers auth-cookie-value all-iteration-result-atom
                                      websocket-client)))
        (is (= num-requests (count @all-iteration-result-atom)))
        (is (every? #{:success} (vals @all-iteration-result-atom)) (str @all-iteration-result-atom))
        (is (pos? (num-instances waiter-url service-id)))
        (Thread/sleep 1000) ;; allow metrics to be sync-ed
        (let [service-data (service-settings waiter-url service-id)
