Hi Nicholas
On Fri, May 2, 2014 at 4:05 AM, Nicholas Campelia <[email protected]>wrote: > Is there a recommended way to subscribe to multiple producers/Flows? Is > it just to merge the incoming data and then use a case statement in an any > kind of following map statement. > Currently there is only two-way merge, but we will support merging a stream of Producers, too -- it is just not done yet. > > For example, imagine trying to write a kind of leftJoin, is that doable? > What do you mean by leftJoin? > > Also, successive calls to merge (in order to merge several streams will > oversample early streams right? given that the documentation indicates that > if there are values from multiple streams one is picked randomly) > Yes, using two-way merges to implement an n-way merge will be unfair. We will provide generalizations for those cases. Some interesting pending tickets to show the direction: https://github.com/akka/akka/issues/15089 https://github.com/akka/akka/issues/15079 https://github.com/akka/akka/issues/15091 https://github.com/akka/akka/issues/15082 > > Finally, is there any way to maintain state in a transformation. For > example, could you write a cumulative sum transformation for a stream in > longs? > Yes, it is definitely possible! You can look at the "transform" combinator, that expresses a large class of these kind of operations. Be prepared though that we still change a lot of things. -Endre > -- > >>>>>>>>>> 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. > -- Akka Team Typesafe - The software stack for applications that scale Blog: letitcrash.com Twitter: @akkateam -- >>>>>>>>>> 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.
