From efb6db4cc9bdafc0486e84269282ece1c32f51b4 Mon Sep 17 00:00:00 2001 From: michelou Date: Wed, 18 Jul 2007 16:36:42 +0000 Subject: minor change --- src/library/scala/concurrent/MailBox.scala | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/library/scala/concurrent/MailBox.scala b/src/library/scala/concurrent/MailBox.scala index 8488dd7ed2..ebe3ff8f05 100644 --- a/src/library/scala/concurrent/MailBox.scala +++ b/src/library/scala/concurrent/MailBox.scala @@ -57,11 +57,11 @@ class MailBox extends AnyRef with ListQueueCreator { */ private def scanSentMsgs[A](receiver: Receiver[A]): Unit = synchronized { messageQueue.extractFirst(sent, msg => receiver.isDefinedAt(msg)) match { - case None => receivers = receiverQueue.append(receivers, receiver) - case Some((msg, withoutMsg)) => { + case None => + receivers = receiverQueue.append(receivers, receiver) + case Some((msg, withoutMsg)) => sent = withoutMsg receiver.msg = msg - } } } @@ -72,12 +72,12 @@ class MailBox extends AnyRef with ListQueueCreator { */ def send(msg: Message): Unit = synchronized { receiverQueue.extractFirst(receivers, r => r.isDefinedAt(msg)) match { - case None => sent = messageQueue.append(sent, msg) - case Some((receiver, withoutReceiver)) => { + case None => + sent = messageQueue.append(sent, msg) + case Some((receiver, withoutReceiver)) => receivers = withoutReceiver receiver.msg = msg receiver synchronized { receiver.notify() } - } } } -- cgit v1.2.3