Reformat with latest scalafmt

Author: sirthias

compat-akka/src/main/scala/io/bullet/borer/compat/akka.scala

@@ -167,7 +167,7 @@ object akka {
     def readBytes(length: Long, pp: Input.PaddingProvider[ByteString]): ByteString = {
       val remaining = (byteString.length - _cursor).toLong
       val len       = math.min(remaining, length).toInt
-      val bytes =
+      val bytes     =
         if (len > 0) {
           val c = _cursor
           _cursor = c + len

compat-akka/src/main/scala/io/bullet/borer/compat/akkaHttp.scala

@@ -170,7 +170,7 @@ trait AkkaHttpCompat {
   final def borerStreamUnmarshaller[T: Decoder](
       ess: EntityStreamingSupport): FromEntityUnmarshaller[Source[T, NotUsed]] =
     Unmarshaller.withMaterializer { implicit ec => implicit mat =>
-      val unmarshalSync = (byteString: ByteString) => Json.decode(byteString.toArray[Byte]).to[T].value
+      val unmarshalSync     = (byteString: ByteString) => Json.decode(byteString.toArray[Byte]).to[T].value
       val unmarshallingFlow =
         if (ess.parallelism > 1) {
           val unmarshalAsync = (byteString: ByteString) => Future(unmarshalSync(byteString))
@@ -206,7 +206,7 @@ trait AkkaHttpCompat {
       classTag: ClassTag[T]): ToEntityMarshaller[Source[T, NotUsed]] = {
 
     type Marshallings = List[Marshalling[MessageEntity]]
-    val contentType = ess.contentType
+    val contentType                                                    = ess.contentType
     val selectMarshalling: Marshallings => Option[() => MessageEntity] =
       contentType match {
         case _: ContentType.Binary | _: ContentType.WithFixedCharset | _: ContentType.WithMissingCharset =>

compat-akka/src/test/scala/io/bullet/borer/compat/AkkaHttpSupportSpec.scala

@@ -70,7 +70,7 @@ class AkkaHttpSupportSpec extends BorerSuite {
   }
 
   test("prefer JSON on equal q-value (by default)") {
-    val foo = Foo("bar")
+    val foo          = Foo("bar")
     val acceptHeader = _root_.akka.http.scaladsl.model.headers.Accept(
       MediaRange.One(`application/json`, 1.0f),
       MediaRanges.`*/*`

compat-cats/src/main/scala/io/bullet/borer/compat/cats.scala

@@ -36,7 +36,7 @@ object cats {
   implicit def iorDecoder[A: Decoder, B: Decoder]: Decoder[Ior[A, B]] =
     Decoder { r =>
       var breakExpected = false
-      val open = if (r.tryReadArrayStart()) { breakExpected = true; -1L }
+      val open          = if (r.tryReadArrayStart()) { breakExpected = true; -1L }
       else r.readArrayHeader()
       val result =
         r.readInt() match {
@@ -107,7 +107,7 @@ object cats {
   implicit def validatedDecoder[E: Decoder, A: Decoder]: Decoder[Validated[E, A]] =
     Decoder { r =>
       val breakExpected = r.tryReadArrayStart() || { r.readMapHeader(1); false }
-      val result =
+      val result        =
         r.readInt() match {
           case 0 => Validated.Invalid(r.read[E]())
           case 1 => Validated.Valid(r.read[A]())

compat-circe/src/main/scala/io/bullet/borer/compat/circe.scala

@@ -99,7 +99,7 @@ object circe {
       import DataItem.{Shifts => DIS}
 
       private[this] val arrayDecoder = Decoder.fromFactory(this, implicitly[Factory[Json, Vector[Json]]])
-      private[this] val mapDecoder =
+      private[this] val mapDecoder   =
         Decoder { r =>
           val buf = new scala.collection.mutable.ArrayBuilder.ofRef[(String, Json)]
           if (r.hasMapHeader)

compat-pekko/src/main/scala/io/bullet/borer/compat/pekko.scala

@@ -167,7 +167,7 @@ object pekko {
     def readBytes(length: Long, pp: Input.PaddingProvider[ByteString]): ByteString = {
       val remaining = (byteString.length - _cursor).toLong
       val len       = math.min(remaining, length).toInt
-      val bytes =
+      val bytes     =
         if (len > 0) {
           val c = _cursor
           _cursor = c + len

compat-pekko/src/main/scala/io/bullet/borer/compat/pekkoHttp.scala

@@ -174,7 +174,7 @@ trait PekkoHttpCompat {
   final def borerStreamUnmarshaller[T: Decoder](
       ess: EntityStreamingSupport): FromEntityUnmarshaller[Source[T, NotUsed]] =
     Unmarshaller.withMaterializer { implicit ec => implicit mat =>
-      val unmarshalSync = (byteString: ByteString) => Json.decode(byteString.toArray[Byte]).to[T].value
+      val unmarshalSync     = (byteString: ByteString) => Json.decode(byteString.toArray[Byte]).to[T].value
       val unmarshallingFlow =
         if (ess.parallelism > 1) {
           val unmarshalAsync = (byteString: ByteString) => Future(unmarshalSync(byteString))
@@ -210,7 +210,7 @@ trait PekkoHttpCompat {
       classTag: ClassTag[T]): ToEntityMarshaller[Source[T, NotUsed]] = {
 
     type Marshallings = List[Marshalling[MessageEntity]]
-    val contentType = ess.contentType
+    val contentType                                                    = ess.contentType
     val selectMarshalling: Marshallings => Option[() => MessageEntity] =
       contentType match {
         case _: ContentType.Binary | _: ContentType.WithFixedCharset | _: ContentType.WithMissingCharset =>

compat-pekko/src/test/scala/io/bullet/borer/compat/PekkoHttpSupportSpec.scala

@@ -70,7 +70,7 @@ class PekkoHttpSupportSpec extends BorerSuite {
   }
 
   test("prefer JSON on equal q-value (by default)") {
-    val foo = Foo("bar")
+    val foo          = Foo("bar")
     val acceptHeader = _root_.org.apache.pekko.http.scaladsl.model.headers.Accept(
       MediaRange.One(`application/json`, 1.0f),
       MediaRanges.`*/*`
@@ -114,7 +114,7 @@ class PekkoHttpSupportSpec extends BorerSuite {
   }
 
   test("stream marshalling (JSON)") {
-    val nums = List(Num(1), Num(2), Num(3))
+    val nums         = List(Num(1), Num(2), Num(3))
     val acceptHeader =
       _root_.org.apache.pekko.http.scaladsl.model.headers.Accept(MediaRange.One(`application/json`, 1.0f))
     Marshal(nums)

compat-scodec/src/main/scala/io/bullet/borer/compat/scodec.scala

@@ -141,7 +141,7 @@ object scodec {
     def readBytes(length: Long, pp: Input.PaddingProvider[ByteVector]) = {
       val remaining = byteVector.length - _cursor
       val len       = math.min(remaining, length)
-      val bytes =
+      val bytes     =
         if (len > 0) {
           val c = _cursor
           _cursor = c + len

core/.jvm/src/main/scala/io/bullet/borer/internal/Unsafe.scala

@@ -85,7 +85,7 @@ object Unsafe:
       if (source.length > 0)
         val copySource =
           if (this.byteOrder != byteOrder)
-            val array = new Array[Short](source.length)
+            val array                               = new Array[Short](source.length)
             @tailrec def rec(ix: Int): Array[Short] =
               if (ix < array.length)
                 array(ix) = java.lang.Short.reverseBytes(source(ix))
@@ -102,7 +102,7 @@ object Unsafe:
       if (source.length > 0)
         val copySource =
           if (this.byteOrder != byteOrder)
-            val array = new Array[Int](source.length)
+            val array                             = new Array[Int](source.length)
             @tailrec def rec(ix: Int): Array[Int] =
               if (ix < array.length)
                 array(ix) = java.lang.Integer.reverseBytes(source(ix))
@@ -119,7 +119,7 @@ object Unsafe:
       if (source.length > 0)
         val copySource =
           if (this.byteOrder != byteOrder)
-            val array = new Array[Long](source.length)
+            val array                              = new Array[Long](source.length)
             @tailrec def rec(ix: Int): Array[Long] =
               if (ix < array.length)
                 array(ix) = java.lang.Long.reverseBytes(source(ix))