1

我的 Play 2.2 应用程序有一些奇怪的行为，我不确定如何调试它。在我开始使用 iteratees 之前，我的代码运行良好。

我的演员创建​​了一个如下所示的枚举器并将其发送回调用者：

val emailFeed = Concurrent.unicast[Message] (
          onStart = {
            pushee => {
              log.debug("Pushing 1")
              pushee.push(messages.apply(0))
              log.debug("Pushed 1")

            }
            },
          onComplete = {
            log.debug("Done with pushee")
          },
          onError = {
            (msg, in) => log.error(msg)
          }

然后调用者通过以下方式使用它：

f.map { reply =>
        val emailFeed = reply.asInstanceOf[Enumerator[Message]]
        val iter =  Iteratee.fold[Message,String] ("") {
          (result, msg) =>   {
             Logger.debug("appending subj")
             result ++ msg.getSubject()
             Logger.debug(" subj appended")
             result
          }
        }
        val result: Future[String] = emailFeed |>>> iter
        Await.result(result, 10 minutes)

问题是 Await.result 超时。我已经逐步浏览了 iteratee 代码并看到它被调用了。只需处理 1 个块，因此速度很快。我还在控制台中看到了枚举器和迭代调试 stmts。我只是不知道为什么它没有完成：

[debug] application - Pushing 1
[debug] application - Pushed 1
[debug] application - appending subj
[debug] application -  subj appended
4

1 回答 1

2

显然，如果您忘记正确结束枚举器，Play 中没有太多反馈。您必须致电：

pushee.end

或者

pushee.eofAndEnd

触发枚举器关闭和未来完成。

于 2013-10-24T18:41:26.033 回答