scala - 玩! 2 WS 库 : Detect and Handle Closed Connection in Streaming HTTP response

Question

在 play WS 库中，我使用这个调用来处理流式 http 响应:

 def get[A](consumer: ResponseHeaders => Iteratee[Array[Byte], A]):
     Future[Iteratee[Array[Byte], A]]

我正在传递类似这样的内容:_ => (Iteratee.foreach(chunk => println(chunk)))

一切正常，但有时连接似乎会关闭，我不知道如何处理。我尝试添加 .mapDone 以在 Iteratee 完成时打印出一些内容，但它从未发生过。

在这个 get 请求中，我如何检测到连接已关闭并处理该事件？

Answer 1

Play 2.2.3 似乎不再是这个问题了。当流关闭时，应使用 Unit 调用如下定义的传递给 map 的函数:

val connection = WS.url("http://example.com")
  .get(_ => iteratee).flatMap(_.run) map { _ => println("closed") }