I have an example of a chat server that uses web sockets and SSE at
https://github.com/cretz/scala-web-ideal/tree/master/server/src/main/scala/webideal/chat
(specifically ChatRoom.scala) which is basically taken from
https://github.com/jrudolph/akka-http-scala-js-websocket-chat
and added SSE.
Either by implementing ActorPublisher like you have done or by using
Source.actorRef.
Read more about both those here:
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/scala/stream-integrations.html#Source_actorRef
Note that you will have to make sure to handle back pressure yoursel
That library nicely answers my first question, thanks.
Still, my second question is more general: how do I create Source backed by
an Actor? My SSE events come from an Actor. I am really new to Akka Streams
(just because of handling SSE in Akka HTTP). Now I have implemented my
custom ActorPubli
Have you seen Heiko Seebergers akka-sse library?
Does what you want, or if you cannot use it, is a good example of how to do
it.
https://github.com/hseeberger/akka-sse
--
Johan Andrén
Typesafe - Reactive apps on the JVM
Twitter: @apnylle
--
>> Read the docs: http://akka.io/docs
