在“调度”库中等待超时响应

Question

我要用Dispatch写一个简单的HTTP客户端，我调用dispatch.Http得到一个未来，调用未来得到响应

val request = ...
val future = Http(request) // call the server asynchronously
val response = future() // wait for the response from the server

现在我想知道我怎么能等待超时。我希望最后一个API调用是：

// throw an exception if no response received within timeout
val response = future(timeout: Long)

这有意义吗？

我知道Dispatch返回scala.concurrent.Future，它不提供带有超时的API。你建议我如何实现它？

Answer 1

首先，您可以使用wait：

import scala.concurrent.Await
import scala.concurrent.duration._

Await.result(future, 10 seconds) //you can specify timeout here

问题在于，如果future未能在指定的超时时间内返回，它将抛出异常。

如果您需要更大的灵活性，这里是第二种方法：

val futureTimeout = Promise.timeout("Timed out" /* or throw new RuntimeException("timed out") */, 10 seconds)
Future.firstCompletedOf(Seq(futureResult, futureTimeout)).map {
  case result: SomeType => //do something
  case timedOut: SomeOtherType => //handle timeout
}

Answer 2

您可以创建配置的Http客户端：

val httpApplicationClient = http . configure(_。setRequestTimeoutInMs(3000))

val future = httpApplicationClient（request）

...