diff options
Diffstat (limited to 'src/main/scala')
-rw-r--r-- | src/main/scala/kamon/instrumentation/PromiseInstrumentation.scala | 24 |
1 files changed, 0 insertions, 24 deletions
diff --git a/src/main/scala/kamon/instrumentation/PromiseInstrumentation.scala b/src/main/scala/kamon/instrumentation/PromiseInstrumentation.scala index f1aec404..a39bc4ad 100644 --- a/src/main/scala/kamon/instrumentation/PromiseInstrumentation.scala +++ b/src/main/scala/kamon/instrumentation/PromiseInstrumentation.scala @@ -44,28 +44,4 @@ class PromiseInstrumentation { proceed(getArgs.updated(0, wrappedFunction)) } - @Pointcut("execution(* scala.concurrent.impl.Future$.apply(..)) && args(body, executor)") - def registeringApplyOnFuture(body: () => Any, executor: ExecutionContext) = {} - - @Around("registeringApplyOnFuture(body, executor)") - def aroundApplyOnFuture(pjp:ProceedingJoinPoint, body: () => Any, executor: ExecutionContext) = { - import pjp._ - - val wrappedBody = wrapFutureBody(traceContext)(body) - proceed(getArgs.updated(0, wrappedBody)) - } - - def wrapFutureBody[A](ctx:Option[TraceContext])(block: => A) : A = { - ctx match { - case Some(ctx) => { - println("Wrapping body") - TraceContext.set(ctx) - val result = block - TraceContext.clear - result - } - case None => block - } - } - } |