From b625b56ee3e08e136cfa7c4f938fef8710d1a2b2 Mon Sep 17 00:00:00 2001
From: Derek Williams <derek@nebvin.ca>
Date: Fri, 11 Feb 2011 15:12:35 -0700
Subject: [PATCH] Throw an exception if Future.await is called on an expired
 and uncompleted Future. Ref #659

---
 akka-actor/src/main/scala/akka/dispatch/Future.scala | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/akka-actor/src/main/scala/akka/dispatch/Future.scala b/akka-actor/src/main/scala/akka/dispatch/Future.scala
index 60a16218c7..fa3a1964d4 100644
--- a/akka-actor/src/main/scala/akka/dispatch/Future.scala
+++ b/akka-actor/src/main/scala/akka/dispatch/Future.scala
@@ -224,6 +224,8 @@ class DefaultCompletableFuture[T](timeout: Long) extends CompletableFuture[T] {
           wait = wait - (currentTimeInNanos - start)
       }
     }
+    if (!_value.isDefined)
+      throw new FutureTimeoutException("Futures timed out after [" + timeout + "] milliseconds")
     this
   } finally {
     _lock.unlock