sender inside a future

by

You are making a very common mistake of “closing over mutable state”. The closure you pass to onComplete does not make a copy of this.sender, so when your onComplete gets called, you are sending the message to whatever this.sender happens to point to at that time, not what it pointed to when you created the closure.

You can avoid this problem by creating your own local, immutable copy of the current contents of this.sender, and reference that value in the closure:

val origSender = sender
f.onComplete {
    case Successs(x) => origSender ! x
    ...
}

More Related Contents:

  1. No configuration setting found for key ‘akka.version’
  2. How to create a Source that can receive elements later via a method call?
  3. Accessing the underlying ActorRef of an akka stream Source created by Source.actorRef
  4. Akka Kill vs. Stop vs. Poison Pill?
  5. How to restrict actor messages to specific types?
  6. What’s the difference between => , ()=>, and Unit=>
  7. What is the purpose of type ascriptions in Scala?
  8. What is the advantage of using abstract classes instead of traits?
  9. Provide schema while reading csv file as a dataframe
  10. How to flatmap a nested Dataframe in Spark
  11. Is there a way to control which implicit conversion will be the default used?
  12. Why can’t I return a concrete subtype of A if a generic subtype of A is declared as return parameter?
  13. how to filter out a null value from spark dataframe
  14. Is there a reason not to use SparkContext.getOrCreate when writing a spark job?
  15. What are the various join types in Spark?
  16. What is the rule for parenthesis in Scala method invocation?
  17. Method Override with Scala 3 Macros
  18. How to calculate the size of dataframe in bytes in Spark?
  19. Why does partition parameter of SparkContext.textFile not take effect?
  20. Can I zip more than two lists together in Scala?
  21. Usages of Null / Nothing / Unit in Scala
  22. Cross product in Scala
  23. Spark Scala list folders in directory
  24. Spark-Monotonically increasing id not working as expected in dataframe?
  25. Reading in multiple files compressed in tar.gz archive into Spark [duplicate]
  26. How can I convert immutable.Map to mutable.Map in Scala?
  27. Install sbt on ubuntu [closed]
  28. Should I use the final modifier when declaring case classes?
  29. Scala equivalent of Java’s Number
  30. Difference between two rows in Spark dataframe

Leave a Comment