summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/actors/scala/actors/Future.scala4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/actors/scala/actors/Future.scala b/src/actors/scala/actors/Future.scala
index d3ba1be380..14c838bf0f 100644
--- a/src/actors/scala/actors/Future.scala
+++ b/src/actors/scala/actors/Future.scala
@@ -71,6 +71,8 @@ object Futures {
* </p>
*/
def awaitAll(timeout: Long, fts: Future[Any]*): List[Option[Any]] = {
+ TimerThread.requestTimeout(Actor.self, null, timeout)
+
var resultsMap: collection.mutable.Map[Int, Option[Any]] = new collection.mutable.HashMap[Int, Option[Any]]
var cnt = 0
@@ -111,7 +113,7 @@ object Futures {
}
}
}
- Actor.receiveWithin(timeout)(reaction)
+ Actor.receive(reaction)
}
awaitWith(partFuns)