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 yourself when you do this. Happy hAkking! -- Johan Andrén Typesafe - Reactive apps on the JVM Twitter: @apnylle On Friday, August 7, 2015 at 12:04:41 PM UTC+2, 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.
