diff --git a/common/src/main/scala/net/psforever/objects/guid/TaskResolver.scala b/common/src/main/scala/net/psforever/objects/guid/TaskResolver.scala index 275416cc..96e7ecce 100644 --- a/common/src/main/scala/net/psforever/objects/guid/TaskResolver.scala +++ b/common/src/main/scala/net/psforever/objects/guid/TaskResolver.scala @@ -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)