Play Websocket proxy for pub sub API

Question

>尝试在Play中编写一个websocket，该Websocket将依次向另一个API发出请求以获取订阅并通过Web套接字将数据流式传输回客户端。

我可以轻松创建一个简单的网络套接字

def timeFeed = WebSocket.using[String] { implicit request =>
    val in = Iteratee.ignore[String]
    val out = Enumerator.repeatM( play.api.libs.concurrent.Promise.timeout(
      getTimeAndLog, 1000
    ))
    (in, out)
  }

如何从我在 API 上调用的源创建枚举器？

Answer 1

def timeFeed = WebSocket.using[String] { implicit request =>
    val in = Iteratee.ignore[String]
    val out = Enumerator.GenerateM( Future {
      getTimeAndLog
  })
    (in, out)
}

调用 GenerateM 而不是重复将获得预期的结果