diff options
Diffstat (limited to 'src/main/scala/scala/async/continuations/AsyncWithCPSFallback.scala')
-rw-r--r-- | src/main/scala/scala/async/continuations/AsyncWithCPSFallback.scala | 9 |
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) + } } |