在Play 2.1中，使用什么来代替过时的PushEnumerator
在Play 2.1中，使用什么来代替过时的PushEnumerator
提问于 2013-01-30 01:05:14
PushEnumerator在Play Framework2.1-RC中被弃用。文档告诉我改用Concurrent.broadcast。但是，我推送的数据依赖于用户，所以我不能将相同的数据广播给每个用户。
换句话说，Concurrent.broadcast将给我一个连接到许多迭代器的枚举器，而我需要许多枚举器连接到许多迭代器。
回答 1
Stack Overflow用户
回答已采纳
发布于 2013-04-13 09:38:01
下面是一个使用Concurrent.unicastE的简单示例
// assume the following exist:
def readValueAsync(source: MySource): Future[Any]
val source: MySource = ...
// this is where the meat is:
val valueEnumerator = Concurrent.unicast[Any] {
(channel: Concurrent.Channel[Any]) =>
readValueAsync(source) onComplete {
case Success(x: Any) => channel.push(x)
case Failure(t) => channel.end(t)
}
}
// you can then collect it using an iteratee
// since my enumerator never really ends, I only take 10 elements here
val result: List[Any] =
valueEnumerator through Enumeratee.take(10) run Interatee.getChunks[Any]页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/14588218
复制相关文章
相似问题
腾讯云开发者
