Hi, I think it is the `takeWithin` operation what you are looking for.
-Endre On Wed, Jan 20, 2016 at 12:53 PM, <bchaza...@companywatch.net> wrote: > I forgot to mention that I am using akka-streams 2.0.1. > > > On Wednesday, 20 January 2016 11:52:43 UTC, bcha...@companywatch.net > wrote: >> >> Hi everyone, >> >> I have got an infinite stream (from reactive-kafka) which I want to >> filter and materialize into a finite collection with Sink.seq. >> >> The stream never finishes but I would like to consider it completed if >> it's idle for a period of time. The method Flow.idleTimeout looks >> interesting but I would actually like to get the materailzed value out of >> Sink.seq, and I think I need the stream to complete successfully for that, >> rather than failed with a TimeoutException. >> >> My question is this: how can I make my stream complete successfully after >> a given idle period and get the materialized value out? >> >> Thanks for your help. >> >> This message is intended only for the addressee and may contain >> information that is confidential or privileged. Unauthorised use is >> strictly prohibited and may be unlawful. If you are not the addressee, you >> should not read, copy, disclose or otherwise use this message, except for >> the purpose of delivery to the addressee. If you have received this in >> error, please delete and advise us immediately. Although Company Watch >> makes every reasonable effort to keep its network and systems free from >> viruses, the company accepts no responsibility for computer viruses >> transmitted through this mail or in any attachments. It is your >> responsibility to virus scan any attachments we send to you. >> >> Company Watch Limited is a company registered in England & Wales with >> company number 3597613 >> Centurion House, 37 Jewry Street, London, EC3N 2ER >> >> Please consider the environment before printing this email >> >> > This message is intended only for the addressee and may contain > information that is confidential or privileged. Unauthorised use is > strictly prohibited and may be unlawful. If you are not the addressee, you > should not read, copy, disclose or otherwise use this message, except for > the purpose of delivery to the addressee. If you have received this in > error, please delete and advise us immediately. Although Company Watch > makes every reasonable effort to keep its network and systems free from > viruses, the company accepts no responsibility for computer viruses > transmitted through this mail or in any attachments. It is your > responsibility to virus scan any attachments we send to you. > > Company Watch Limited is a company registered in England & Wales with > company number 3597613 > Centurion House, 37 Jewry Street, London, EC3N 2ER > > Please consider the environment before printing this email > > -- > >>>>>>>>>> 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 https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - Reactive apps on the JVM Blog: letitcrash.com Twitter: @akkateam -- >>>>>>>>>> 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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
