scala - 在 Play 2.1 中，使用什么代替已弃用的 PushEnumerator

Question

PushEnumerator 在 Play 框架 2.1-RC 中已弃用。
文档告诉我改用 Concurrent.broadcast。但是，我推送的数据取决于用户，因此我无法向每个用户广播相同的数据。

换句话说， Concurrent.broadcast 会给我一个连接到许多迭代器的枚举器，而我需要许多连接到许多迭代器的枚举器。

Answer 1

下面是一个使用 Concurrent.unicast[E] 的简单示例:

// 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]