True, I missed that option. On Tue, Apr 12, 2016 at 11:37 AM, Roland Kuhn <[email protected]> wrote:
> Well, you could also concat an EOF marker and use that to flush … > > 12 apr 2016 kl. 11:33 skrev Endre Varga <[email protected]>: > > No, for that you need to write a custom stage. > > -Endre > > On Tue, Apr 12, 2016 at 11:01 AM, Arno Haase < > [email protected]> wrote: > >> Hi Endre, >> >> thanks for the reply. Is there any way I can get statefulMapConcat to >> emit cached data after upstream is completed? >> >> - Arno >> >> Am 12.04.2016 um 09:27 schrieb Endre Varga: >> > 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] >> > <mailto:[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] >> > <mailto:akka-user%[email protected]>. >> > To post to this group, send email to [email protected] >> > <mailto:[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] >> > <mailto:[email protected]>. >> > To post to this group, send email to [email protected] >> > <mailto:[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. >> > > > -- > >>>>>>>>>> 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. > -- >>>>>>>>>> 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.
