Add a retry for a check for stopped actors #21122

This commit is contained in:
Martynas Mickevičius 2016-10-19 09:33:28 +03:00
parent 6cbfed975b
commit b9da5a76de

View file

@ -204,10 +204,7 @@ class ActorsLeakSpec extends AkkaSpec(ActorsLeakSpec.config) with ImplicitSender
EventFilter[TimeoutException](occurrences = 1).intercept {} EventFilter[TimeoutException](occurrences = 1).intercept {}
val finalActors = targets.flatMap(collectLiveActors).toSet awaitAssert(assertResult(initialActors)(targets.flatMap(collectLiveActors).toSet), 5.seconds)
assertResult(initialActors)(finalActors)
} }
} }