changed logic in aroundPostStop in regards to onSuccess

This commit is contained in:
FateJH 2017-10-26 19:33:04 -04:00
parent 33403c24dd
commit 14213affe0

View file

@ -32,7 +32,7 @@ class TaskResolver() extends Actor {
*/
timeoutCleanup.cancel()
TimeoutCleanup()
OnSuccess()
tasks.filter(entry => entry.task.isComplete == Task.Resolution.Success).foreach(entry => OnSuccess(entry.task) )
val ex : Throwable = new Exception(s"a task is being stopped")
tasks.foreach(entry => {
OnFailure(entry.task, ex)