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

Will always infer type as Any, so should explicitly state it.

Browse source
This commit is contained in:
Derek Williams 2011-05-02 09:09:14 -06:00
parent c7444193e6
commit 2d2bdeec7a
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -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