Hi, maybe the problem is to use sender() in a Future, try instead:
case UpdateStudent(_, c) =>
val actualSender = sender()
Future[Student] {
val updatedStudent = student.copy(counter = student.counter + c)
student = updatedStudent
log.info(sender().toString())
updatedStudent
}(executionContext).map(updatedStudent => actualSender ! updatedStudent)
Sender is a function, and it's evaluated when the future ends, so the sender
maybe has change
El viernes, 13 de octubre de 2017, 18:59:42 (UTC+2), Danny Lesnik escribió:
>
> I have the following stateful Actor
>
> class StudentActor extends Actor with ActorLogging{
>
> var student:Student = Student(id,firstName,lastName)
>
> implicit val executionContext = Try {
> context.system.dispatchers.lookup("blocking-code-dispatcher")
> }.getOrElse(context.system.dispatcher)
>
>
> override def receive = {
>
> case UpdateStudent(_, c) =>
> Future[Student] {
>
> val updatedStudent = student.copy(counter = student.counter + c)
> student = updatedStudent
> log.info(sender().toString())
> updatedStudent
> }(executionContext).map(updatedStudent => sender() ! updatedStudent)
>
> case GetStudent(id,_) => sender() ! student
>
> }
> }
>
>
>
> When I try to use ask pattern to update this student from main method, I'm
> receiving timeout
>
>
> holder.ask(UpdateStudent("1")).mapTo[Student].foreach(println(_))
>
>
> However, if I remove Future method and using the following code it works like
> charm:
>
>
> case UpdateStudent(_, c) => val updatedStudent =
> student.copy(counter = student.counter + c)
>
> student = updatedStudent
> log.info(sender().toString())
> updatedStudent
>
> sender() ! updatedStudent
>
>
> Why using Future in partial method causes ask timeout?
>
> I believe this is something stupid, but I can't figure it out :)
>
>
--
>>>>>>>>>> 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 https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
