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.
For example, imagine trying to write a kind of leftJoin, is that doable? 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) 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? -- >>>>>>>>>> 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.
