Enabled synchronous message sends for Replyable...

Enabled synchronous message sends for ReplyableReactor. Added
get(timeout: Long) method to SyncVar.

1 files changed, 14 insertions, 0 deletions

diff --git a/src/library/scala/concurrent/SyncVar.scala b/src/library/scala/concurrent/SyncVar.scala
index 3b35c9ef10..d64c2fa51c 100644
--- a/src/library/scala/concurrent/SyncVar.scala
+++ b/src/library/scala/concurrent/SyncVar.scala
@@ -28,6 +28,20 @@ class SyncVar[A] {
     else throw exception.get
   }
 
+  def get(timeout: Long): Option[A] = synchronized {
+    if (!isDefined) {
+      try {
+        wait(timeout)
+      } catch {
+        case _: InterruptedException =>
+      }
+    }
+    if (exception.isEmpty) {
+      if (isDefined) Some(value) else None
+    } else
+      throw exception.get
+  }
+
   def take() = synchronized {
     try {
       get