From 2b9f7be1a7a2abe7c4623e0770dd9699bd58e657 Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Sun, 25 Apr 2010 18:07:27 +0200 Subject: [PATCH] Added Future[T] as return type for await and awaitBlocking --- akka-core/src/main/scala/dispatch/Future.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/akka-core/src/main/scala/dispatch/Future.scala b/akka-core/src/main/scala/dispatch/Future.scala index 7e8fd5b087..7fe0c4ab6a 100644 --- a/akka-core/src/main/scala/dispatch/Future.scala +++ b/akka-core/src/main/scala/dispatch/Future.scala @@ -71,8 +71,8 @@ object Futures { } sealed trait Future[T] { - def await - def awaitBlocking + def await : Future[T] + def awaitBlocking : Future[T] def isCompleted: Boolean def isExpired: Boolean def timeoutInNanos: Long @@ -111,6 +111,7 @@ class DefaultCompletableFuture[T](timeout: Long) extends CompletableFuture[T] { wait = wait - (currentTimeInNanos - start) } } + this } finally { _lock.unlock } @@ -120,6 +121,7 @@ class DefaultCompletableFuture[T](timeout: Long) extends CompletableFuture[T] { while (!_completed) { _signal.await } + this } finally { _lock.unlock }