反应式Web应用程序读取Twitter流Play Scala

Question

我正在尝试遵循曼宁Reactive Web applications的Twitter流示例本书基于PlayFramework 2.5，但是我想使用较新版本的框架，因为为什么不这样做。本书示例使用了第三方库https://github.com/jroper/play-iteratees-extras，该库似乎不适用于更新的Play版本。该示例使用此库对从twitter接收的流进行编码，并创建Json对象的迭代。我的问题是，有什么方法可以使用现有的Scala / Play API绕过该库吗？

这段代码是下一个：

val jsonStream: Enumerator[JsObject] =
    enumerator &>
    Encoding.decode() &>
    Enumeratee.grouped(JsonIteratees.jsSimpleObject)

val loggingIteratee = Iteratee.foreach[JsObject] { value =>
    Logger.info(value.toString)
}

我试图不使用解码部分并创建JsObject的Iteratee，但是在迭代过程中出现错误：

对象Iteratee不接受类型参数。

关于如何绕过此库的任何提示？

Answer 1

我也遇到了同样的问题，经过一番搜索后发现the solution using Akka Streams。希望有帮助。