Apply formatter on scala files.
MODIFY
dd-java-agent/instrumentation/akka-http-10.0/src/main/scala/datadog/trace/instrumentation/akkahttp/AkkaHttpClientTransformFlow.scala
dd-java-agent/instrumentation/akka-http-10.0/src/main/scala/datadog/trace/instrumentation/akkahttp/AkkaHttpClientTransformFlow.scala
@@ -4,11 +4,10 @@ import java.util.Collections
import akka.NotUsed
import akka.http.scaladsl.model.{HttpRequest, HttpResponse}
-import akka.stream.Supervision
import akka.stream.scaladsl.Flow
import datadog.trace.api.{DDSpanTypes, DDTags}
+import io.opentracing.Span
import io.opentracing.log.Fields.ERROR_OBJECT
-import io.opentracing.{Scope, Span}
import io.opentracing.propagation.Format
import io.opentracing.tag.Tags
import io.opentracing.util.GlobalTracer

MODIFY
dd-java-agent/instrumentation/akka-http-10.0/src/test/scala/AkkaHttpTestWebServer.scala
dd-java-agent/instrumentation/akka-http-10.0/src/test/scala/AkkaHttpTestWebServer.scala
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.Http.ServerBinding
-import akka.http.scaladsl.model._
import akka.http.scaladsl.model.HttpMethods.GET
+import akka.http.scaladsl.model._
import akka.stream.ActorMaterializer
import datadog.trace.agent.test.TestUtils
import datadog.trace.api.Trace

MODIFY
dd-java-agent/instrumentation/java-concurrent/akka-testing/src/main/scala/AkkaActors.scala
dd-java-agent/instrumentation/java-concurrent/akka-testing/src/main/scala/AkkaActors.scala
@@ -26,8 +26,10 @@ object AkkaActors {
}
class AkkaActors {
+
import AkkaActors._
import Greeter._
+
implicit val timeout: Timeout = 5.minutes
@Trace
@@ -54,11 +56,15 @@ class AkkaActors {
object Greeter {
def props(message: String, receiverActor: ActorRef): Props = Props(new Greeter(message, receiverActor))
+
final case class WhoToGreet(who: String)
+
case object Greet
+
}
class Greeter(message: String, receiverActor: ActorRef) extends Actor {
+
import Greeter._
import Receiver._
@@ -74,10 +80,13 @@ class Greeter(message: String, receiverActor: ActorRef) extends Actor {
object Receiver {
def props: Props = Props[Receiver]
+
final case class Greeting(greeting: String)
+
}
class Receiver extends Actor with ActorLogging {
+
import Receiver._
def receive = {

MODIFY
dd-java-agent/instrumentation/java-concurrent/src/slickTest/scala/SlickUtils.scala
dd-java-agent/instrumentation/java-concurrent/src/slickTest/scala/SlickUtils.scala
@@ -3,10 +3,11 @@ import datadog.trace.context.TraceScope
import io.opentracing.util.GlobalTracer
import slick.jdbc.H2Profile.api._
-import scala.concurrent.{Await, Future}
import scala.concurrent.duration.Duration
+import scala.concurrent.{Await, Future}
class SlickUtils {
+
import SlickUtils._
val database = Database.forURL(Url,

MODIFY
dd-java-agent/instrumentation/play-2.4/src/latestDepTest/scala/Play26TestUtils.scala
dd-java-agent/instrumentation/play-2.4/src/latestDepTest/scala/Play26TestUtils.scala
-import play.api.mvc.Action
-import play.api.routing.{HandlerDef, Router}
-import play.api.mvc._
-import play.api.routing.sird._
import java.lang.reflect.Field
import datadog.trace.api.Trace
-import play.api.libs.typedmap.TypedKey
import play.api.mvc.request.RequestAttrKey
+import play.api.mvc.{Action, _}
+import play.api.routing.sird._
+import play.api.routing.{HandlerDef, Router}
-import scala.concurrent.{Await, Future}
import scala.concurrent.duration._
+import scala.concurrent.{Await, Future}
object Play26TestUtils {

MODIFY
dd-java-agent/instrumentation/play-2.4/src/test/scala/Play24TestUtils.scala
dd-java-agent/instrumentation/play-2.4/src/test/scala/Play24TestUtils.scala
import java.lang.reflect.Field
-import play.api.mvc.Action
+import datadog.trace.api.Trace
+import play.api.inject.bind
+import play.api.mvc.{Action, _}
import play.api.routing.Router
-import play.api.mvc._
import play.api.routing.sird._
-import datadog.trace.api.Trace
import play.inject.DelegateInjector
-import scala.concurrent.{Await, Future}
-import scala.concurrent.duration._
-import play.api.inject.bind
-
import scala.concurrent.ExecutionContext.Implicits.global
+import scala.concurrent.duration._
+import scala.concurrent.{Await, Future}
object Play24TestUtils {
def buildTestApp(): play.Application = {

Apply formatter on scala files.