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. You can see how the actors are created/used in those two places.
On Friday, August 7, 2015 at 5:04:41 AM UTC-5, Maxymilian Śmiech wrote: > > 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 ActorPublisher which is created by Source.actorPublisher(...) > > W dniu czwartek, 6 sierpnia 2015 11:26:56 UTC+2 użytkownik Johan Andrén > napisał: >> >> 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/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
