Fixing erronous test

2010-12-28 19:26:04 +01:00 · 2010-12-28 19:26:04 +01:00 · 9309c98bb9
commit 9309c98bb9
parent d0f94b9e19
1 changed files with 5 additions and 4 deletions
--- a/akka-remote/src/test/scala/remote/ServerInitiatedRemoteActorSpec.scala
+++ b/akka-remote/src/test/scala/remote/ServerInitiatedRemoteActorSpec.scala
@ -173,10 +173,11 @@ class ServerInitiatedRemoteActorSpec extends AkkaRemoteTest {
      remoteFoo.!(10)(Some(remoteBar))

      val latch = new CountDownLatch(100)
-      while(
-        (remoteFoo !! "done").as[Boolean].getOrElse(false) &&
-        (remoteBar !! "done").as[Boolean].getOrElse(false)
-      ) {
+
+      def testDone() = (remoteFoo !! "done").as[Boolean].getOrElse(false) &&
+                       (remoteBar !! "done").as[Boolean].getOrElse(false)
+
+      while(!testDone()) {
        if (latch.await(200, TimeUnit.MILLISECONDS))
          error("Test didn't complete within 100 cycles")
        else