Changes based on review. See #2230

This commit is contained in:
Björn Antonsson 2012-06-21 16:10:04 +02:00
parent 4e49b2c843
commit 9710cceacb

View file

@ -268,8 +268,7 @@ abstract class MultiNodeSpec(val myself: RoleName, _system: ActorSystem, _roles:
testConductor.removeNode(myself)
within(testConductor.Settings.BarrierTimeout.duration) {
awaitCond {
val nodes = testConductor.getNodes.await
nodes.size < 1 || (nodes.size == 1 && nodes.head == myself)
testConductor.getNodes.await.filterNot(_ == myself).isEmpty
}
}
}