diff options
author | Diego Parra <dparra@despegar.com> | 2013-05-24 10:57:31 -0300 |
---|---|---|
committer | Diego Parra <dparra@despegar.com> | 2013-05-24 10:57:31 -0300 |
commit | 8d17e06079ac26b1d5154121accf5bb932e49f45 (patch) | |
tree | 0af5408ce6602ae7b19a60489ef2d535fc11d546 /src | |
parent | 4dab50d280053b410dbb421c7f8a0182c8b27b78 (diff) | |
download | Kamon-8d17e06079ac26b1d5154121accf5bb932e49f45.tar.gz Kamon-8d17e06079ac26b1d5154121accf5bb932e49f45.tar.bz2 Kamon-8d17e06079ac26b1d5154121accf5bb932e49f45.zip |
remove unused code
Diffstat (limited to 'src')
-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 - } - } - } |