Hello, I'm currently testing to migrate a larger and complex actor system, one pattern we have is an aggregate and flush kind of operation. An actor receives a set of updates that is applied incrementally to a state. Every n seconds or x updates that state is flushed to the database.
The updates are easy: just a scan operation that aggregates the changes. For the flush I have two (one not feasible) ideas so far: - a groupedWithin that just takes the last element from the list (not possible when there are thousand of updates per second) - a custom actor (seems like a lot of overhead) Are there any easier / better solutions? Thanks, Elmar -- >>>>>>>>>> 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.
