Reformat with scalafmt 3.8.4

Executed command: scalafmt --non-interactive
typelevel · Jan 13, 2025 · 887a49a · 887a49a
1 parent 7ea4da8
commit 887a49a
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 13 deletions.
diff --git a/core/shared/src/main/scala/fs2/concurrent/Signal.scala b/core/shared/src/main/scala/fs2/concurrent/Signal.scala
@@ -481,8 +481,11 @@ object SignallingMapRef {
       .map { case (state, ids) =>
         def newId = ids.getAndUpdate(_ + 1)
 
-        def updateAndNotify[U](state: State, k: K, f: Option[V] => (Option[V], U))
-            : (State, F[U]) = {
+        def updateAndNotify[U](
+            state: State,
+            k: K,
+            f: Option[V] => (Option[V], U)
+        ): (State, F[U]) = {
 
           val keyState = state.keys.get(k)
 

diff --git a/core/shared/src/test/scala/fs2/StreamPerformanceSuite.scala b/core/shared/src/test/scala/fs2/StreamPerformanceSuite.scala
@@ -198,9 +198,8 @@ class StreamPerformanceSuite extends Fs2Suite {
                 val s: Stream[SyncIO, Int] =
                   List
                     .fill(N)(bracketed)
-                    .foldLeft(Stream.raiseError[SyncIO](new Err): Stream[SyncIO, Int]) {
-                      (acc, hd) =>
-                        acc.handleErrorWith(_ => hd)
+                    .foldLeft(Stream.raiseError[SyncIO](new Err): Stream[SyncIO, Int]) { (acc, hd) =>
+                      acc.handleErrorWith(_ => hd)
                     }
                 s.compile.toList.attempt
                   .flatMap(_ => (ok.get, open.get).tupled)

diff --git a/io/jvm/src/test/scala/fs2/io/IoPlatformSuite.scala b/io/jvm/src/test/scala/fs2/io/IoPlatformSuite.scala
@@ -64,12 +64,11 @@ class IoPlatformSuite extends Fs2Suite {
                 (bs1.length != (o1 + l1)) &&
                 // we expect that next slice will wrap same buffer
                 ((bs2 eq bs1) && (o2 == o1 + l1))
-              } || {
-                // if first slice buffer is 'full'
-                (bs2.length == (o1 + l1)) &&
-                // we expect new buffer allocated for next slice
-                ((bs2 ne bs1) && (o2 == 0))
-              }
+              } ||
+              // if first slice buffer is 'full'
+              (bs2.length == (o1 + l1)) &&
+              // we expect new buffer allocated for next slice
+              ((bs2 ne bs1) && (o2 == 0))
             case _ => false // unexpected chunk subtype
           }
       }

diff --git a/protocols/shared/src/main/scala-2/fs2/protocols/pcapng/BlockCodec.scala b/protocols/shared/src/main/scala-2/fs2/protocols/pcapng/BlockCodec.scala
@@ -44,8 +44,9 @@ object BlockCodec {
     ("Block Total Length"     | constant(length.bv)                 )}
   // format: on
 
-  def unknownByteOrder[L <: HList, LB <: HList](hexConstant: ByteVector)(f: Length => Codec[L])(
-      implicit
+  def unknownByteOrder[L <: HList, LB <: HList](
+      hexConstant: ByteVector
+  )(f: Length => Codec[L])(implicit
       prepend: Prepend.Aux[L, Unit :: HNil, LB],
       init: Init.Aux[LB, L],
       last: Last.Aux[LB, Unit]