1

我正在创建一个 SSE 简单示例,我使用 Scalatra 创建了一个 API,并通过 header 的间隔获取响应text/event-stream。看起来 Scalatra 不支持这种类型。这是我的简单代码,

 get("/hello") {
    val headers = Map(
      "Cache-Control" -> "no-cache",
      "Content-Type" -> "text/event-stream",
      "Connection" -> "close")
    Ok("data: hello world", headers)
  }

但我只收到来自服务器的消息。我想做类似的事情akka-http

get {
      complete {
        Source.tick(2.seconds, 2.seconds, ())
          .map(_ => LocalTime.now())
          .map(dateTimeToServerSentEvent)
          .via(WithHeartbeats(1.second))
      }
    }

你们知道如何从 Scalatra获取事件流吗?谢谢你。

4

0 回答 0