2

我想逐步为 WebSocket 输出 Iteratee 提供几个枚举器(例如,当我通过 Websocket 输入 iteratee 接收到特定事件时,我想向输出 Iteratee 添加一个特定的枚举器)。

如果我是对的,如果我只是(in,out)在 Websocket 函数参数的末尾返回,这是不可能的,因为 out 已经是一个不可变的枚举器:

WebSocket.using[JsValue] { request =>
    val in: Iteratee[JsValue,Unit] = ...
    val out: Enumerator[JsValue] = ...

    (in, out)
}

我认为 Concurrent.PatchPannel 是我正在寻找的,但我无法理解如何使用它。有没有人有使用 Concurrent.PatchPannel 的例子?(如果这确实是我正在寻找的)。

谢谢

4

1 回答 1

5

我终于自己找到了解决方案。

编辑:请参阅我的博客文章中的“可混合子流”部分:http: //atamborrino.github.io/play/2013/12/25/play-framework-websocket.html

于 2012-12-26T10:01:06.957 回答