diff options
| -rw-r--r-- | src/library/scala/concurrent/Channel.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/library/scala/concurrent/Channel.scala b/src/library/scala/concurrent/Channel.scala index bab6345ab9..e2bef53710 100644 --- a/src/library/scala/concurrent/Channel.scala +++ b/src/library/scala/concurrent/Channel.scala @@ -36,7 +36,7 @@ class Channel[a] { } def read: a = synchronized { - if (null == written.next) { + while (null == written.next) { nreaders = nreaders + 1; wait(); nreaders = nreaders - 1 } val x = written.elem |