Reformat with scalafmt 3.10.4

Executed command: scalafmt --non-interactive

Author: scala-steward

build.sbt

@@ -44,7 +44,8 @@ inThisBuild(Def.settings(
   concurrentRestrictions in Global += Tags.limit(Tags.Test, 1),
   onLoad in Global := {
     sLog.value.info(
-      s"Building Pekko HTTP ${version.value} against Pekko ${PekkoCoreDependency.version} on Scala ${(httpCore / scalaVersion).value}")
+      s"Building Pekko HTTP ${version.value} against Pekko ${PekkoCoreDependency.version} on Scala ${(httpCore /
+        scalaVersion).value}")
     (onLoad in Global).value
   },
   projectInfoVersion := (if (isSnapshot.value) "snapshot" else version.value),
@@ -424,8 +425,10 @@ lazy val docs = project("docs")
       "javadoc.org.apache.pekko.link_style" -> "direct",
       "scaladoc.org.apache.pekko.base_url" -> s"https://pekko.apache.org/api/pekko/${PekkoCoreDependency.default.link}",
       "scaladoc.org.apache.pekko.link_style" -> "direct",
-      "javadoc.org.apache.pekko.http.base_url" -> s"https://pekko.apache.org/japi/pekko-http/${projectInfoVersion.value}",
-      "scaladoc.org.apache.pekko.http.base_url" -> s"https://pekko.apache.org/api/pekko-http/${projectInfoVersion.value}",
+      "javadoc.org.apache.pekko.http.base_url" ->
+      s"https://pekko.apache.org/japi/pekko-http/${projectInfoVersion.value}",
+      "scaladoc.org.apache.pekko.http.base_url" ->
+      s"https://pekko.apache.org/api/pekko-http/${projectInfoVersion.value}",
       "github.base_url" -> GitHub.url(version.value, isSnapshot.value)),
     apidocRootPackage := "org.apache.pekko",
     ValidatePR / additionalTasks += Compile / paradox)

docs/src/test/scala/docs/http/scaladsl/HttpServerExampleSpec.scala

@@ -361,19 +361,18 @@ class HttpServerExampleSpec extends AnyWordSpec with Matchers
     // needed for the future flatMap/onComplete in the end
     implicit val executionContext = system.dispatcher
 
-    val route =
-      (put & path("lines")) {
-        withoutSizeLimit {
-          extractDataBytes { bytes =>
-            val finishedWriting = bytes.runWith(FileIO.toPath(new File("/tmp/example.out").toPath))
-
-            // we only want to respond once the incoming data has been handled:
-            onComplete(finishedWriting) { ioResult =>
-              complete("Finished writing data: " + ioResult)
-            }
+    val route = (put & path("lines")) {
+      withoutSizeLimit {
+        extractDataBytes { bytes =>
+          val finishedWriting = bytes.runWith(FileIO.toPath(new File("/tmp/example.out").toPath))
+
+          // we only want to respond once the incoming data has been handled:
+          onComplete(finishedWriting) { ioResult =>
+            complete("Finished writing data: " + ioResult)
           }
         }
       }
+    }
     // #consume-raw-dataBytes
   }
 
@@ -388,19 +387,18 @@ class HttpServerExampleSpec extends AnyWordSpec with Matchers
     // needed for the future flatMap/onComplete in the end
     implicit val executionContext = system.dispatcher
 
-    val route =
-      (put & path("lines")) {
-        withoutSizeLimit {
-          extractRequest { (r: HttpRequest) =>
-            val finishedWriting = r.discardEntityBytes().future
-
-            // we only want to respond once the incoming data has been handled:
-            onComplete(finishedWriting) { done =>
-              complete("Drained all data from connection... (" + done + ")")
-            }
+    val route = (put & path("lines")) {
+      withoutSizeLimit {
+        extractRequest { (r: HttpRequest) =>
+          val finishedWriting = r.discardEntityBytes().future
+
+          // we only want to respond once the incoming data has been handled:
+          onComplete(finishedWriting) { done =>
+            complete("Drained all data from connection... (" + done + ")")
           }
         }
       }
+    }
     // #discard-discardEntityBytes
   }
 
@@ -416,22 +414,21 @@ class HttpServerExampleSpec extends AnyWordSpec with Matchers
     // needed for the future flatMap/onComplete in the end
     implicit val executionContext = system.dispatcher
 
-    val route =
-      (put & path("lines")) {
-        withoutSizeLimit {
-          extractDataBytes { data =>
-            // Closing connections, method 1 (eager):
-            // we deem this request as illegal, and close the connection right away:
-            data.runWith(Sink.cancelled) // "brutally" closes the connection
-
-            // Closing connections, method 2 (graceful):
-            // consider draining connection and replying with `Connection: Close` header
-            // if you want the client to close after this request/reply cycle instead:
-            respondWithHeader(Connection("close"))
-            complete(StatusCodes.Forbidden -> "Not allowed!")
-          }
+    val route = (put & path("lines")) {
+      withoutSizeLimit {
+        extractDataBytes { data =>
+          // Closing connections, method 1 (eager):
+          // we deem this request as illegal, and close the connection right away:
+          data.runWith(Sink.cancelled) // "brutally" closes the connection
+
+          // Closing connections, method 2 (graceful):
+          // consider draining connection and replying with `Connection: Close` header
+          // if you want the client to close after this request/reply cycle instead:
+          respondWithHeader(Connection("close"))
+          complete(StatusCodes.Forbidden -> "Not allowed!")
         }
       }
+    }
     // #discard-close-connections
   }
 

docs/src/test/scala/docs/http/scaladsl/server/CaseClassExtractionExamplesSpec.scala

@@ -55,12 +55,11 @@ class CaseClassExtractionExamplesSpec extends RoutingSpec with Inside {
     // #example-3
     case class Color(name: String, red: Int, green: Int, blue: Int)
 
-    val route =
-      (path("color" / Segment) & parameters("r".as[Int], "g".as[Int], "b".as[Int]))
-        .as(Color.apply _) { color =>
-          // ... route working with the `color` instance
-          doSomethingWith(color) // #hide
-        }
+    val route = (path("color" / Segment) & parameters("r".as[Int], "g".as[Int], "b".as[Int]))
+      .as(Color.apply _) { color =>
+        // ... route working with the `color` instance
+        doSomethingWith(color) // #hide
+      }
     Get("/color/abc?r=1&g=2&b=3") ~> route ~> check { responseAs[String] shouldEqual "Color(abc,1,2,3)" } // #hide
     // #example-3
   }
@@ -77,7 +76,7 @@ class CaseClassExtractionExamplesSpec extends RoutingSpec with Inside {
   "example 4 test" in {
     val route =
       (path("color" / Segment) &
-        parameters("r".as[Int], "g".as[Int], "b".as[Int])).as(Color.apply _) { color =>
+      parameters("r".as[Int], "g".as[Int], "b".as[Int])).as(Color.apply _) { color =>
         // ... route working with the `color` instance
         doSomethingWith(color) // #hide
       }

docs/src/test/scala/docs/http/scaladsl/server/DirectiveExamplesSpec.scala

@@ -102,10 +102,9 @@ class DirectiveExamplesSpec extends RoutingSpec with CompileOnlySpec {
   "example-6" in {
     // #example-6
     val getOrPut = get | put
-    val route =
-      (path("order" / IntNumber) & getOrPut & extractMethod) { (id, m) =>
-        complete(s"Received ${m.name} request for order $id")
-      }
+    val route = (path("order" / IntNumber) & getOrPut & extractMethod) { (id, m) =>
+      complete(s"Received ${m.name} request for order $id")
+    }
     verify(route) // #hide
     // #example-6
   }

docs/src/test/scala/docs/http/scaladsl/server/directives/HeaderDirectivesExamplesSpec.scala

@@ -71,10 +71,9 @@ class HeaderDirectivesExamplesSpec extends RoutingSpec with CompileOnlySpec with
       case _                                       => None
     }
 
-    val route =
-      (headerValue(extractExampleHeader) | provide("newValue")) { value =>
-        complete(s"headerValue $value")
-      }
+    val route = (headerValue(extractExampleHeader) | provide("newValue")) { value =>
+      complete(s"headerValue $value")
+    }
 
     // tests:
     Get("/") ~> RawHeader("exampleHeaderValue", "theHeaderValue") ~> route ~> check {

docs/src/test/scala/docs/http/scaladsl/server/directives/ParameterDirectivesExamplesSpec.scala

@@ -121,7 +121,8 @@ class ParameterDirectivesExamplesSpec extends RoutingSpec with CompileOnlySpec w
 
     Get("/?color=blue&count=blub") ~> Route.seal(route) ~> check {
       status shouldEqual StatusCodes.BadRequest
-      responseAs[String] shouldEqual "The query parameter 'count' was malformed:\n'blub'" +
+      responseAs[String] shouldEqual
+      "The query parameter 'count' was malformed:\n'blub'" +
       " is not a valid 32-bit signed integer value"
     }
     // #mapped-value

docs/src/test/scala/docs/http/scaladsl/server/directives/RouteDirectivesExamplesSpec.scala

@@ -162,7 +162,8 @@ class RouteDirectivesExamplesSpec extends RoutingSpec with CompileOnlySpec {
 
     Get("/foo") ~> route ~> check {
       status shouldEqual StatusCodes.PermanentRedirect
-      responseAs[String] shouldEqual """The request, and all future requests should be repeated using <a href="/foo/">this URI</a>."""
+      responseAs[String] shouldEqual
+      """The request, and all future requests should be repeated using <a href="/foo/">this URI</a>."""
     }
     // #redirect-examples
   }

http-bench-jmh/src/main/scala/org/apache/pekko/http/impl/engine/MessageToFrameRendererBenchmark.scala

@@ -23,14 +23,7 @@ import scala.concurrent.Await
 import scala.concurrent.duration.{ Duration, DurationInt }
 
 import org.openjdk.jmh.annotations.{
-  Benchmark,
-  BenchmarkMode,
-  Mode,
-  OperationsPerInvocation,
-  OutputTimeUnit,
-  Scope,
-  State,
-  TearDown
+  Benchmark, BenchmarkMode, Mode, OperationsPerInvocation, OutputTimeUnit, Scope, State, TearDown
 }
 
 import org.apache.pekko

http-bench-jmh/src/main/scala/org/apache/pekko/http/impl/engine/http2/H2RequestResponseBenchmark.scala

@@ -19,13 +19,7 @@ import org.apache.pekko
 import pekko.http.impl.engine.http2.FrameEvent.{ DataFrame, HeadersFrame }
 import pekko.http.impl.engine.http2.framing.FrameRenderer
 import pekko.http.scaladsl.model.{
-  AttributeKeys,
-  ContentTypes,
-  HttpEntity,
-  HttpMethods,
-  HttpRequest,
-  HttpResponse,
-  Trailer
+  AttributeKeys, ContentTypes, HttpEntity, HttpMethods, HttpRequest, HttpResponse, Trailer
 }
 import pekko.http.scaladsl.model.HttpEntity.{ Chunk, LastChunk }
 import pekko.http.scaladsl.model.headers.RawHeader

http-core/src/main/scala/org/apache/pekko/http/impl/engine/client/PoolMasterActor.scala

@@ -16,13 +16,7 @@ package org.apache.pekko.http.impl.engine.client
 import org.apache.pekko
 import pekko.Done
 import pekko.actor.{
-  Actor,
-  ActorLogging,
-  ActorRef,
-  DeadLetterSuppression,
-  Deploy,
-  ExtendedActorSystem,
-  NoSerializationVerificationNeeded,
+  Actor, ActorLogging, ActorRef, DeadLetterSuppression, Deploy, ExtendedActorSystem, NoSerializationVerificationNeeded,
   Props
 }
 import pekko.annotation.InternalApi