Fix for error while generating scaladocs

2011-08-02 13:38:02 -06:00 · 2011-08-02 13:38:02 -06:00 · 00494cf95d
commit 00494cf95d
parent 053dbf3b60
1 changed files with 1 additions and 1 deletions
--- a/akka-actor/src/main/scala/akka/dispatch/Future.scala
+++ b/akka-actor/src/main/scala/akka/dispatch/Future.scala
@ -310,7 +310,7 @@ object Future {
  def flow[A](body: ⇒ A @cps[Future[Any]])(implicit dispatcher: MessageDispatcher, timeout: Timeout): Future[A] = {
    val future = Promise[A](timeout)
    //dispatcher dispatchTask { () ⇒
-    reify(body) foreachFull (future completeWithResult, future completeWithException) onException {
+    (reify(body) foreachFull (future completeWithResult, future completeWithException): Future[Any]) onException {
      case e: Exception ⇒ future completeWithException e
    }
    //}