From e9f498a1df3328d46eca8940f4bd2cbb2dc9af71 Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Thu, 14 Jul 2011 11:26:38 +0200 Subject: [PATCH] Unbreaking the build, adding missing file to checkin, I apologize for the inconvenience --- .../src/main/scala/akka/testkit/CallingThreadDispatcher.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-testkit/src/main/scala/akka/testkit/CallingThreadDispatcher.scala b/akka-testkit/src/main/scala/akka/testkit/CallingThreadDispatcher.scala index 19058b4951..3017613398 100644 --- a/akka-testkit/src/main/scala/akka/testkit/CallingThreadDispatcher.scala +++ b/akka-testkit/src/main/scala/akka/testkit/CallingThreadDispatcher.scala @@ -140,7 +140,7 @@ class CallingThreadDispatcher(val warnings: Boolean = true) extends MessageDispa private[akka] override def dispatch(handle: MessageInvocation) { val mbox = getMailbox(handle.receiver) val queue = mbox.queue - val execute = mbox.suspended.ifElseYield { + val execute = mbox.suspended.fold { queue.push(handle) if (warnings && handle.channel.isInstanceOf[Promise[_]]) { EventHandler.warning(this, "suspended, creating Future could deadlock; target: %s" format handle.receiver) @@ -177,7 +177,7 @@ class CallingThreadDispatcher(val warnings: Boolean = true) extends MessageDispa assert(queue.isActive) mbox.lock.lock val recurse = try { - val handle = mbox.suspended.ifElseYield[MessageInvocation] { + val handle = mbox.suspended.fold[MessageInvocation] { queue.leave null } {