Thanks! Always good to learn about new methods :)
On Thu, Mar 10, 2016 at 6:50 AM, Viktor Klang <viktor.kl...@gmail.com>
wrote:
> There's also: someSource.zip(Source.fromIterator(() => Iterator.from(0)))
>
> On Thu, Mar 10, 2016 at 3:42 PM, Akka Team <akka.offic...@gmail.com>
> wrote:
>
>> Hi Richard,
>>
>> I would say in general being able to achieve what you want by composition
>> rather than a multitude of special stages is what we strive for with akka
>> streams. There is also a big difference between the regular collections and
>> the streams that streams might be infinite, parallell, cyclic etc, and in
>> those cases a zipWithIndex might not make sense.
>>
>> You could also achieve what you describe with a single stage using
>> statefulMapConcat like this:
>>
>> import scala.collection.immutable.Iterable
>> val flow: Flow[String, (String, Long), NotUsed] =
>> Flow[String].statefulMapConcat { () =>
>> var index = 0L
>> def next = {
>> index += 1
>> index
>> }
>>
>> (string) => Iterable((string, next))
>> }
>>
>>
>> --
>> Johan Andrén
>> Akka Team, Lightbend Inc.
>>
>> --
>> >>>>>>>>>> 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.
>>
>
>
>
> --
> Cheers,
> √
>
> --
> >>>>>>>>>> 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.
>
--
>>>>>>>>>> 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.
