From 705f76aa41ebdf9384530e2e0d850a0ef703a5e6 Mon Sep 17 00:00:00 2001 From: Ivan Topolnjak Date: Wed, 18 Dec 2013 20:41:20 -0300 Subject: more reformatted code --- .../trace/instrumentation/FutureTracingSpec.scala | 30 ++++++++++------------ 1 file changed, 13 insertions(+), 17 deletions(-) (limited to 'kamon-trace/src/test/scala/kamon/trace/instrumentation/FutureTracingSpec.scala') diff --git a/kamon-trace/src/test/scala/kamon/trace/instrumentation/FutureTracingSpec.scala b/kamon-trace/src/test/scala/kamon/trace/instrumentation/FutureTracingSpec.scala index 9989bfca..339fe6be 100644 --- a/kamon-trace/src/test/scala/kamon/trace/instrumentation/FutureTracingSpec.scala +++ b/kamon-trace/src/test/scala/kamon/trace/instrumentation/FutureTracingSpec.scala @@ -15,16 +15,15 @@ * ========================================================== */ package kamon.trace.instrumentation -import scala.concurrent.{ExecutionContext, Await, Promise, Future} -import org.scalatest.{Matchers, OptionValues, WordSpec} -import org.scalatest.concurrent.{ScalaFutures, PatienceConfiguration} +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.util.{ Random, Success } import scala.concurrent.duration._ import java.util.concurrent.TimeUnit -import akka.actor.{Actor, ActorSystem} -import kamon.trace.{Trace, TraceContext} - +import akka.actor.{ Actor, ActorSystem } +import kamon.trace.{ Trace, TraceContext } class FutureTracingSpec extends WordSpec with Matchers with ScalaFutures with PatienceConfiguration with OptionValues { @@ -39,9 +38,8 @@ class FutureTracingSpec extends WordSpec with Matchers with ScalaFutures with Pa future = Future(Trace.context) } - whenReady(future)( ctxInFuture => - ctxInFuture should equal(testTraceContext) - ) + whenReady(future)(ctxInFuture ⇒ + ctxInFuture should equal(testTraceContext)) } "must be available when executing callbacks on the future" in new TraceContextFixture { @@ -50,14 +48,13 @@ class FutureTracingSpec extends WordSpec with Matchers with ScalaFutures with Pa 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()) + .map(_.length) + .flatMap(len ⇒ Future(len.toString)) + .map(s ⇒ Trace.context()) } - whenReady(future)( ctxInFuture => - ctxInFuture should equal(testTraceContext) - ) + whenReady(future)(ctxInFuture ⇒ + ctxInFuture should equal(testTraceContext)) } } } @@ -68,4 +65,3 @@ class FutureTracingSpec extends WordSpec with Matchers with ScalaFutures with Pa } } - -- cgit v1.2.3