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

Changing 'flow' to use onException instead of other boilerplate

Browse source
This commit is contained in:
Viktor Klang 2011-07-11 14:51:23 +02:00
parent 3c98cce8f0
commit 24250d0da6
1 changed files with 1 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -267,12 +267,7 @@ object Future {
*/
def flow[A](body: ⇒ A @cps[Future[Any]], timeout: Long = Actor.TIMEOUT): Future[A] = {
val future = Promise[A](timeout)
(reset(future.asInstanceOf[Promise[Any]].completeWithResult(body)): Future[Any]) onComplete {
_.exception match {
case Some(e) ⇒ future completeWithException e
case None ⇒
}
}
(reset(future.asInstanceOf[Promise[Any]].completeWithResult(body)): Future[Any]) onException { case e => future completeWithException e }
future
}
}