spotless

Author: samwright

instrumentation/pekko/pekko-http-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pekkohttp/v1_0/server/PekkoHttpServerTracer.java

@@ -147,8 +147,8 @@ public void onPush() {
                 // When GraphInterpreterInstrumentation sets `tracingRequest.context` as the current
                 // context, the akka Envelope + Actor instrumentation propagates it all the way
                 // back to here and follows the HttpResponse up the stack of stages.
-                // If http-pipelining is enabled, it will also propagate this context to the handling
-                // of the next request, leading to context-leaking errors.
+                // If http-pipelining is enabled, it will also propagate this context to the
+                // handling of the next request, leading to context-leaking errors.
                 // To prevent this, we reset the context to what it was before creating it.
                 tracingRequest.parentContext.makeCurrent();
 
@@ -175,7 +175,6 @@ public void onUpstreamFailure(Throwable exception) {
               fail(responseOut, exception);
             }
 
-
             @Override
             public void onUpstreamFinish() {
               // End any ongoing spans, though there should be none.

instrumentation/pekko/pekko-http-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pekkohttp/v1_0/server/PekkoTracingRequest.java

@@ -14,7 +14,8 @@
 import org.apache.pekko.http.scaladsl.model.HttpRequest;
 
 public class PekkoTracingRequest implements ImplicitContextKeyed {
-  private static final ContextKey<PekkoTracingRequest> CONTEXT_KEY = named("opentelemetry-pekko-tracing-request");
+  private static final ContextKey<PekkoTracingRequest> CONTEXT_KEY =
+      named("opentelemetry-pekko-tracing-request");
   static final AttributeKey<PekkoTracingRequest> ATTR_KEY =
       new AttributeKey<>("_otel_ctx", PekkoTracingRequest.class);
   static final PekkoTracingRequest EMPTY = new PekkoTracingRequest(null, null, null);

instrumentation/pekko/pekko-http-1.0/javaagent/src/test/scala/io/opentelemetry/javaagent/instrumentation/pekkohttp/v1_0/PekkoHttpTestAsyncWebServer.scala

@@ -64,7 +64,8 @@ object PekkoHttpTestAsyncWebServer {
     if (null == binding) {
       import scala.concurrent.duration._
       binding = Await.result(
-        Http().bindAndHandleAsync(asyncHandler, "localhost", port, parallelism = 2),
+        Http()
+          .bindAndHandleAsync(asyncHandler, "localhost", port, parallelism = 2),
         10.seconds
       )
     }