aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/scala/async/continuations/AsyncWithCPSFallback.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/scala/scala/async/continuations/AsyncWithCPSFallback.scala')
-rw-r--r--src/main/scala/scala/async/continuations/AsyncWithCPSFallback.scala9
1 files changed, 7 insertions, 2 deletions
diff --git a/src/main/scala/scala/async/continuations/AsyncWithCPSFallback.scala b/src/main/scala/scala/async/continuations/AsyncWithCPSFallback.scala
index fe6e1a6..e0da5aa 100644
--- a/src/main/scala/scala/async/continuations/AsyncWithCPSFallback.scala
+++ b/src/main/scala/scala/async/continuations/AsyncWithCPSFallback.scala
@@ -13,8 +13,13 @@ import scala.concurrent.Future
trait AsyncWithCPSFallback extends AsyncBaseWithCPSFallback with ScalaConcurrentCPSFallback
object AsyncWithCPSFallback extends AsyncWithCPSFallback {
+ import scala.concurrent.{ExecutionContext, Future}
- def async[T](body: T) = macro asyncImpl[T]
+ def async[T](body: T)(implicit execContext: ExecutionContext): Future[T] = macro asyncImpl[T]
- override def asyncImpl[T: c.WeakTypeTag](c: Context)(body: c.Expr[T]): c.Expr[Future[T]] = super.asyncImpl[T](c)(body)
+ override def asyncImpl[T: c.WeakTypeTag](c: Context)
+ (body: c.Expr[T])
+ (execContext: c.Expr[ExecutionContext]): c.Expr[Future[T]] = {
+ super.asyncImpl[T](c)(body)(execContext)
+ }
}