我正在创建一个 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获取事件流吗?谢谢你。