diff options
author | michelou <michelou@epfl.ch> | 2007-07-18 16:36:42 +0000 |
---|---|---|
committer | michelou <michelou@epfl.ch> | 2007-07-18 16:36:42 +0000 |
commit | efb6db4cc9bdafc0486e84269282ece1c32f51b4 (patch) | |
tree | ddd5176fcc8189b8e40ec50822af62f80377fe93 /src | |
parent | 14ea3ab51e7a7712afd4aa94ecbe0d6799f5e4d9 (diff) | |
download | scala-efb6db4cc9bdafc0486e84269282ece1c32f51b4.tar.gz scala-efb6db4cc9bdafc0486e84269282ece1c32f51b4.tar.bz2 scala-efb6db4cc9bdafc0486e84269282ece1c32f51b4.zip |
minor change
Diffstat (limited to 'src')
-rw-r--r-- | src/library/scala/concurrent/MailBox.scala | 12 |
1 files 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() } - } } } |