aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/main/scala/kamon/instrumentation/PromiseInstrumentation.scala24
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
- }
- }
-
}