@Heiko: I heard you loud an clear. Thank you.
I'm still confused, however. So within the onReceive method of an actor, I
understand it's allowed to call pipe like this, correct?
Patterns.pipe(Patterns.ask(otherActor, message, timeout),
context().dispatcher());
If yes, what's the way if I want to wrap the ask result to add some information
for subsequent processing that the otherActor cannot do? Would it be OK to call
something like this?
Patterns.pipe(Patterns.ask(otherActor, message, timeout).map(new Mapper<Object,
Object>() {
@Override
public Object apply(Object parameter) {
return new WrappedMessage(message, otherImmutableParameter);
}
}, context().dispatcher()), context().dispatcher());
Or does using the future's map method again violate the "don't use future
callbacks in actors" rule?
Sorry if this sounds stupid, but wrapping one's head around the Scala–Java
gap ain't easy, at least for me.
--
>>>>>>>>>> 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.
