Я создаю простой пример SSE, я создаю API с помощью Scalatra и получаю ответы по интервалу с заголовком 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?Спасибо.