Given a stream of elements E ordered by some property, how can I group these elements into List[E] as soon as all all elements with the same property are emitted. I want to continue processing each stream element, which now becomes List[E], as soon as possible. groupBy does not work in this case because it demultiplexes stream elements E based on common property into separate output streams, one for each common property, and it doesn't complete until elements of original stream are emitted.
For example, given Source(List(1,1,2,2,2,3,3,3,4)) I want to continue processing List(1,1) as a single stream element as soon as 2 is encountered in the stream. Thank you, Andre Piwoni -- >>>>>>>>>> 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 http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
