Val src = someSource.map(processJSON).alsoTo(somewhereWhichWorksFine) -- Cheers, √ On Apr 22, 2016 9:14 AM, "clca" <claud...@outlook.com> wrote:
> I'm struggling to figure out how to build a stream that does the following: > > Source ~> process (ex. XML2Json) ~> Broadcast[String](2) then out(0) sends > data somewhere (this is working fine) > > out(1) needs to become a Source for a WebSocket endpoint. In this case I > can set the buffer to keep only the N elements considering that a client > may not be always connected. > > Any example? suggestion? I have the E2E workflow working using a sink for > the ws endpoint but I cannot figure out how to make that endpoint a Source. > > > Thanks > Claudio > > -- > >>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- >>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
