aboutsummaryrefslogtreecommitdiff
path: root/kamon-trace/src/test/scala/kamon/FutureTracingSpec.scala
diff options
context:
space:
mode:
authorIvan Topolnjak <ivantopo@gmail.com>2013-11-23 22:54:47 -0300
committerIvan Topolnjak <ivantopo@gmail.com>2013-11-23 22:54:47 -0300
commit7298ddee182f08f7232e8daf8e628b089678f77b (patch)
tree126a64b1e63637ed3b052f7f92b7252350e12a54 /kamon-trace/src/test/scala/kamon/FutureTracingSpec.scala
parentddb000a4510dfce20f7090ac92ea9144403addd6 (diff)
downloadKamon-7298ddee182f08f7232e8daf8e628b089678f77b.tar.gz
Kamon-7298ddee182f08f7232e8daf8e628b089678f77b.tar.bz2
Kamon-7298ddee182f08f7232e8daf8e628b089678f77b.zip
simple test for ActorLogging instrumentation
Diffstat (limited to 'kamon-trace/src/test/scala/kamon/FutureTracingSpec.scala')
-rw-r--r--kamon-trace/src/test/scala/kamon/FutureTracingSpec.scala56
1 files changed, 0 insertions, 56 deletions
diff --git a/kamon-trace/src/test/scala/kamon/FutureTracingSpec.scala b/kamon-trace/src/test/scala/kamon/FutureTracingSpec.scala
deleted file mode 100644
index 1f31d4d2..00000000
--- a/kamon-trace/src/test/scala/kamon/FutureTracingSpec.scala
+++ /dev/null
@@ -1,56 +0,0 @@
-package kamon
-
-import scala.concurrent.{ExecutionContext, Await, Promise, Future}
-import org.scalatest.{Matchers, OptionValues, WordSpec}
-import org.scalatest.concurrent.{ScalaFutures, PatienceConfiguration}
-import java.util.UUID
-import scala.util.{Random, Success}
-import scala.concurrent.duration._
-import java.util.concurrent.TimeUnit
-import akka.actor.{Actor, ActorSystem}
-import kamon.trace.{Trace, TraceContext}
-
-
-class FutureTracingSpec extends WordSpec with Matchers with ScalaFutures with PatienceConfiguration with OptionValues {
-
- implicit val execContext = ExecutionContext.Implicits.global
-
- "a Future created with FutureTracing" should {
- "capture the TraceContext available when created" which {
- "must be available when executing the future's body" in new TraceContextFixture {
- var future: Future[Option[TraceContext]] = _
-
- Trace.withContext(testTraceContext) {
- future = Future(Trace.context)
- }
-
- whenReady(future)( ctxInFuture =>
- ctxInFuture should equal(testTraceContext)
- )
- }
-
- "must be available when executing callbacks on the future" in new TraceContextFixture {
- var future: Future[Option[TraceContext]] = _
-
- Trace.withContext(testTraceContext) {
- future = Future("Hello Kamon!")
- // The TraceContext is expected to be available during all intermediate processing.
- .map (_.length)
- .flatMap(len => Future(len.toString))
- .map (s => Trace.context())
- }
-
- whenReady(future)( ctxInFuture =>
- ctxInFuture should equal(testTraceContext)
- )
- }
- }
- }
-
- trait TraceContextFixture {
- val random = new Random(System.nanoTime)
- val testTraceContext = Some(TraceContext(Actor.noSender, random.nextInt))
- }
-}
-
-