aboutsummaryrefslogtreecommitdiff
path: root/src/test/scala/kamon/instrumentation/FutureInstrumentationSpec.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/test/scala/kamon/instrumentation/FutureInstrumentationSpec.scala')
-rw-r--r--src/test/scala/kamon/instrumentation/FutureInstrumentationSpec.scala23
1 files changed, 16 insertions, 7 deletions
diff --git a/src/test/scala/kamon/instrumentation/FutureInstrumentationSpec.scala b/src/test/scala/kamon/instrumentation/FutureInstrumentationSpec.scala
index 6f2a3678..713d1248 100644
--- a/src/test/scala/kamon/instrumentation/FutureInstrumentationSpec.scala
+++ b/src/test/scala/kamon/instrumentation/FutureInstrumentationSpec.scala
@@ -20,8 +20,7 @@ class FutureInstrumentationSpec extends WordSpec with MustMatchers with ScalaFut
whenReady(futureWithContext) { result =>
result.value must be === testContext
}
- }
- }
+ }}
"should be available during the execution of onComplete callbacks" in { new FutureWithContext {
val onCompleteContext = Promise[TraceContext]()
@@ -33,19 +32,29 @@ class FutureInstrumentationSpec extends WordSpec with MustMatchers with ScalaFut
whenReady(onCompleteContext.future) { result =>
result must be === testContext
}
- }
- }
+ }}
}
}
"created in a thread that doest have a TraceContext" must {
- "not capture any TraceContext" in { new FutureWithoutContext{
+ "not capture any TraceContext for the body execution" in { new FutureWithoutContext{
whenReady(futureWithoutContext) { result =>
result must be === None
}
+ }}
+
+ "not make any TraceContext available during the onComplete callback" in { new FutureWithoutContext {
+ val onCompleteContext = Promise[Option[TraceContext]]()
+
+ futureWithoutContext.onComplete({
+ case _ => onCompleteContext.complete(Success(TraceContext.current))
+ })
+
+ whenReady(onCompleteContext.future) { result =>
+ result must be === None
}
- }
+ }}
}
}
@@ -60,7 +69,7 @@ class FutureInstrumentationSpec extends WordSpec with MustMatchers with ScalaFut
}
trait FutureWithoutContext {
- TraceContext.clear
+ TraceContext.clear // Make sure no TraceContext is available
val futureWithoutContext = Future { TraceContext.current }
}
}