[akka-user] Re: artificially completing an infinite akka stream

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

Re: [akka-user] Re: artificially completing an infinite akka stream

Hi, I think it is the `takeWithin` operation what you are looking for. -Endre On Wed, Jan 20, 2016 at 12:53 PM, 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: >>

Re: [akka-user] Re: artificially completing an infinite akka stream

Yes indeed, that's what I was looking for. Thanks you so much Endre! On Wednesday, 20 January 2016 12:11:38 UTC, Akka Team wrote: > > Hi, > > I think it is the `takeWithin` operation what you are looking for. > > -Endre > > On Wed, Jan 20, 2016 at 12:53 PM, > wrote: