From 2d2bdeec7ac018dcbe6f88936542542b3fbad68a Mon Sep 17 00:00:00 2001 From: Derek Williams Date: Mon, 2 May 2011 09:09:14 -0600 Subject: [PATCH] Will always infer type as Any, so should explicitly state it. --- akka-actor/src/main/scala/akka/dispatch/Future.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-actor/src/main/scala/akka/dispatch/Future.scala b/akka-actor/src/main/scala/akka/dispatch/Future.scala index 1ca3db193a..34e9c6da9b 100644 --- a/akka-actor/src/main/scala/akka/dispatch/Future.scala +++ b/akka-actor/src/main/scala/akka/dispatch/Future.scala @@ -291,8 +291,8 @@ object Future { * * The Delimited Continuations compiler plugin must be enabled in order to use this method. */ - def flow[A](body: => A @cps[Future[A]], timeout: Long = Actor.TIMEOUT): Future[A] = - reset(new DefaultCompletableFuture[A](timeout).completeWithResult(body)) + def flow(body: => Any @cps[Future[Any]], timeout: Long = Actor.TIMEOUT): Future[Any] = + reset(new DefaultCompletableFuture[Any](timeout).completeWithResult(body)) private[akka] val callbacksPendingExecution = new ThreadLocal[Option[Stack[() => Unit]]]() { override def initialValue = None