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.
