scala - Play 2.2 で Future と Iteratee をデバッグする

Question

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 つだけなので、高速です。また、コンソールに列挙子と iteratee デバッグ stmts が表示されます。完了しない理由がわかりません：

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