scala - 如何在具有持久连接的 Playframework 中使用 WS 检测连接关闭？

Question

嗨，我正在做一个连接到 Twitter 流 API 的应用程序，我正在使用 WS 进行这样的连接

WS.url(endpoint).withTimeout(-1).sign(OAuthCalculator(consumerKey, accessToken)).postAndRetrieveStream(parameters)(processResponse(_))

def processResponse(headers: ResponseHeaders) = {
   Iteratee.foreach[Array[Byte]] { chunk =>
     val chunkString = new String(chunk, "UTF-8")
     println(chunkString)
   }
}

我想知道是否有任何方法可以检测连接是否已被 Twitter 关闭

谢谢！

Answer 1

val future: Future[Unit] = WS.url(endpoint).withTimeout(-1).sign(OAuthCalculator(consumerKey, accessToken)).postAndRetrieveStream(parameters)(processResponse(_))

def processResponse(headers: ResponseHeaders) = {
  Iteratee.foreach[Array[Byte]] { chunk =>
    val chunkString = new String(chunk, "UTF-8")
    println(chunkString)
  } 
}

future.map { _ =>
  println("done")
}