2

似乎 reacitvemongo 枚举器没有正确处理异常。下面的代码使用一个枚举器（由 reactivemongo 驱动程序返回）来创建一个列表，这里的问题是，当 fold 函数内部出现异常时，请求挂起并且浏览器根本没有得到响应（加载器无限旋转）

def specialTalks() = AdminAction.async {
implicit request => {
  val query = Json.obj(("status" -> 3))
  val res = talks.find(query).sort(Json.obj(("title" -> 1))).cursor[JsObject]
    .enumerate() |>>> Iteratee.fold[JsObject, List[JsObject]](List[JsObject]())((theList, aTalk) => {
    // an exception may happen here
    if (((aTalk \ "hex").as[String]).length == 24)
      theList :+ aTalk
    else
      theList
  }).map(l => {
    Ok(Json.toJson(Json.obj(("talks" -> l))))
  })
  res.recover({case _ => InternalServerError("Not a hex talk")})
}}

它甚至无法从失败的执行中恢复。

我在这里遗漏了一些东西，或者它是 reactivemongo enumerator 中的错误？

4

1 回答 1

2

Cursor.enumerate() 返回的枚举器存在一个错误，使其无法正确传播应用迭代对象时发生的任何错误。

我已经向 Reactivemongo 团队发送了一个拉取请求来解决这个问题，详细信息可以在这里找到：

https://github.com/ReactiveMongo/ReactiveMongo/pull/191

于 2014-08-08T11:23:40.427 回答