Hi Eric, There is a foreach method that does exactly that. It gives you back a Flow[Unit] which will produce exactly one element at the end of the processing (so you can easily convert it to a Future[Unit] for example).
Is this covering what you need? -Endre On Thu, Jul 24, 2014 at 3:12 AM, Eric Pederson <[email protected]> wrote: > Correction > > def doOnEach(f: T => Unit): Flow[T] > > > -- Eric > > > On Wed, Jul 23, 2014 at 9:10 PM, Eric Pederson <[email protected]> wrote: > >> Hi guys: >> >> Something that would be useful is a side effecting combinator. For >> example, like doOnEach from RxJava. This would be particularly useful in >> the actor world to insert an actor tell into the flow. >> >> def doOnEach(f: => Unit): Flow[T] >> >> For example: >> >> flow.doOnEach { msg => if (msg.isSomething) actor ! msg }.map(....)... >> >> This can be done with a Transformer but it's not really transforming. >> >> Will there be a way to create Flow subtypes so that people can invent >> their own combinators? >> >> Thanks, >> >> -- >> >>>>>>>>>> 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 a topic in the >> Google Groups "Akka User List" group. >> To unsubscribe from this topic, visit >> https://groups.google.com/d/topic/akka-user/qWrA1sqBqiM/unsubscribe. >> To unsubscribe from this group and all its topics, send an email to >> [email protected]. >> >> To post to this group, send email to [email protected]. >> Visit this group at http://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 http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - The software stack for applications that scale 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 [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
