Merge branch 'master' into update/fs2-core-3.10.0

Author: kciesielski

.git-blame-ignore-revs

@@ -0,0 +1,2 @@
+# Scala Steward: Reformat with scalafmt 3.8.1
+499baded20f959dca86ad7a24d2244b7241de8c3

.scala-steward.conf

@@ -3,4 +3,7 @@ updates.ignore = [
   {groupId = "org.scala-lang", artifactId = "scala-compiler", version = "2.13."},
   {groupId = "org.scala-lang", artifactId = "scala-compiler", version = "3."}
 ]
-updates.pin = [{ groupId = "com.typesafe.akka", version = "2.6." }]
+updates.pin = [
+  {groupId = "org.scala-lang", artifactId = "scala3-library", version = "3.3."},
+  {groupId = "com.typesafe.akka", version = "2.6."}
+]

.scalafmt.conf

@@ -1,3 +1,3 @@
 runner.dialect = scala3
-version = 3.7.17
+version = 3.8.1
 maxColumn = 120

build.sbt

@@ -21,7 +21,7 @@ val fs2_2_version: Option[(Long, Long)] => String = {
   case _             => "2.5.9"
 }
 val fs2_3_version = "3.10.0"
-val armeriaVersion = "1.27.2"
+val armeriaVersion = "1.27.3"
 
 excludeLintKeys in Global ++= Set(ideSkipProject)
 
@@ -276,7 +276,7 @@ lazy val vertx = (projectMatrix in file("vertx"))
   .jvmPlatform(
     scalaVersions = List(scala2_12, scala2_13) ++ scala3,
     settings = commonJvmSettings ++ Seq(
-      libraryDependencies += "io.vertx" % "vertx-core" % "4.5.4"
+      libraryDependencies += "io.vertx" % "vertx-core" % "4.5.7"
     )
   )
   .dependsOn(core)

pekko/src/main/scala/sttp/capabilities/pekko/PekkoStreams.scala

@@ -15,8 +15,8 @@ object PekkoStreams extends PekkoStreams {
   def limitBytes(stream: Source[ByteString, Any], maxBytes: Long): Source[ByteString, Any] = {
     stream
       .limitWeighted(maxBytes)(_.length.toLong)
-      .mapError { 
-        case _: pekko.stream.StreamLimitReachedException => StreamMaxLengthExceededException(maxBytes) 
+      .mapError { case _: pekko.stream.StreamLimitReachedException =>
+        StreamMaxLengthExceededException(maxBytes)
       }
   }
 }

pekko/src/test/scala/sttp/capabilities/pekko/PekkoStreamsTest.scala

@@ -36,7 +36,12 @@ class PekkoStreamsTest extends AnyFlatSpec with Matchers with BeforeAndAfterAll
     val stream = PekkoStreams.limitBytes(inputStream, maxBytes)
 
     // then
-    stream.fold(0L)((acc, bs) => acc + bs.length).runWith(TestSink[Long]()).request(1).expectNext(inputByteCount.toLong).expectComplete()
+    stream
+      .fold(0L)((acc, bs) => acc + bs.length)
+      .runWith(TestSink[Long]())
+      .request(1)
+      .expectNext(inputByteCount.toLong)
+      .expectComplete()
   }
 
   it should "Fail stream if limit is exceeded" in {
@@ -51,7 +56,7 @@ class PekkoStreamsTest extends AnyFlatSpec with Matchers with BeforeAndAfterAll
       Source.fromIterator(() => iterator.grouped(chunkSize).map(group => ByteString(group.toArray)))
 
     // when
-    val stream = PekkoStreams.limitBytes(inputStream, maxBytes)    
+    val stream = PekkoStreams.limitBytes(inputStream, maxBytes)
     val probe = stream.runWith(TestSink[ByteString]())
     val _ = for (_ <- 1 to 31) yield probe.requestNext()