Hi Arno, statefulMapConcat is likely what you need. If that does not work, then build a custom stage.
-Endre On Mon, Apr 11, 2016 at 8:09 PM, Arno Haase <[email protected] > wrote: > I have a Source of element type A, and I am looking for a way to build a > stage combining several of them into elements of type B. This is done > based on size and count, and an 'incomplete' instance of B needs to be > generated at the end of the stream. > > Source.mapConcat() with a buffering function that emits whenever enough > instances of A have arrived to create an instance of B pretty much does > what I want, but when the stream is completed, the last bunch of > elements get lost: The function is not notified of stream completion and > can not flush its contents. > > Any ideas or suggestions would be greatly appreciated. > > - Arno > > > -- > >>>>>>>>>> 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 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 [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
