raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Add Promise factory object for creating new CompletableFutures

Browse source
This commit is contained in:
Derek Williams 2011-05-03 18:48:42 -06:00
parent 5b18f18ffd
commit 8752eb5452
1 changed files with 9 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-actor/src/main/scala/akka/dispatch/Future.scala
View file

@ -292,7 +292,7 @@ object Future {
* The Delimited Continuations compiler plugin must be enabled in order to use this method.
*/
def flow[A](body: => A @cps[Future[Any]], timeout: Long = Actor.TIMEOUT): Future[A] = {
val future = new DefaultCompletableFuture[A](timeout)
val future = Promise[A](timeout)
(reset(future.asInstanceOf[CompletableFuture[Any]].completeWithResult(body)): Future[Any]) onComplete { f =>
val opte = f.exception
if (opte.isDefined) future completeWithException (opte.get)
@ -613,6 +613,14 @@ sealed trait Future[+T] {
}
object Promise {
def apply[A](timeout: Long): CompletableFuture[A] = new DefaultCompletableFuture[A](timeout)
def apply[A](): CompletableFuture[A] = apply(Actor.TIMEOUT)
}
/**
* Essentially this is the Promise (or write-side) of a Future (read-side).
*/