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 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.
