Update scalafmt to 3.10.4

Author: mr-git

.scalafmt.conf

@@ -3,7 +3,7 @@
 # - better interop with default IntelliJ IDEA setup (matching import and modifiers sorting logic)
 # - better developer experience on laptop screens (like 16' MBPs) with IntelliJ IDEA (line wraps)
 
-version = 3.10.1
+version = 3.10.4
 
 runner.dialect = scala213source3
 fileOverride {

conhub/src/main/scala/com/evolution/pekko/conhub/ConHubSerializer.scala

@@ -64,8 +64,9 @@ object ConHubSerializer {
 
   private val codecRemoved = (codecs.utf8_32 :: codecVersion).as[RemoteEvent.Event.Removed]
 
-  private val codecDisconnected =
-    (codecs.utf8_32 :: codecFiniteDuration :: codecVersion).as[RemoteEvent.Event.Disconnected]
+  private val codecDisconnected = (codecs.utf8_32 :: codecFiniteDuration :: codecVersion).as[
+    RemoteEvent.Event.Disconnected,
+  ]
 
   private val codecSync = codecsNel(codecValue).as[RemoteEvent.Event.Sync]
 

distributed-data/src/main/scala/com/evolution/pekko/cluster/ddata/SafeReplicator.scala

@@ -10,22 +10,8 @@ import com.evolutiongaming.smetrics.MetricsHelper.*
 import org.apache.pekko.actor.{Actor, ActorLogging, ActorRef, ActorRefFactory, ActorSystem, Props}
 import org.apache.pekko.cluster.ddata.Replicator.{ReadConsistency, WriteConsistency}
 import org.apache.pekko.cluster.ddata.{
-  DistributedData,
-  Flag,
-  GCounter,
-  GSet,
-  Key,
-  LWWMap,
-  ManyVersionVector,
-  ORMap,
-  ORMultiMap,
-  ORSet,
-  OneVersionVector,
-  PNCounter,
-  PNCounterMap,
-  ReplicatedData,
-  Replicator as R,
-  VersionVector,
+  DistributedData, Flag, GCounter, GSet, Key, LWWMap, ManyVersionVector, ORMap, ORMultiMap, ORSet, OneVersionVector,
+  PNCounter, PNCounterMap, ReplicatedData, Replicator as R, VersionVector,
 }
 import org.apache.pekko.pattern.ask
 import org.apache.pekko.util.Timeout

effect-actor-tests/src/test/scala/com/evolution/pekko/effect/actor/tests/ActorOfTest.scala

@@ -6,17 +6,7 @@ import cats.effect.unsafe.implicits.global
 import cats.syntax.all.*
 import com.evolution.pekko.effect.actor.IOSuite.*
 import com.evolution.pekko.effect.actor.{
-  Act,
-  ActorCtx,
-  ActorEffect,
-  ActorOf,
-  ActorRefOf,
-  Ask,
-  Call,
-  Envelope,
-  Receive,
-  ReceiveOf,
-  Tell,
+  Act, ActorCtx, ActorEffect, ActorOf, ActorRefOf, Ask, Call, Envelope, Receive, ReceiveOf, Tell,
 }
 import com.evolution.pekko.effect.testkit.Probe
 import com.evolutiongaming.catshelper.CatsHelper.*

effect-actor-tests/src/test/scala/com/evolution/pekko/effect/actor/tests/CounterSpec.scala

@@ -96,9 +96,10 @@ class CounterSpec extends AsyncFunSuite with ActorSuite with Matchers {
           val expect = (n: Int) =>
             for {
               a <- probe.expect[Int]
-            } yield for {
-              a <- a
-            } yield a.msg shouldEqual n
+            } yield
+              for {
+                a <- a
+              } yield a.msg shouldEqual n
           for {
             a <- expect(1)
             _ <- inc

effect-actor/src/main/scala/com/evolution/pekko/effect/actor/Ask.scala

@@ -104,10 +104,11 @@ object Ask {
       for {
         a <- af(msg)
         b <- self(a, timeout, sender)
-      } yield for {
-        b <- b
-        b <- bf(b)
-      } yield b
+      } yield
+        for {
+          b <- b
+          b <- bf(b)
+        } yield b
     }
 
     def narrow[A1 <: A, B1](
@@ -117,10 +118,11 @@ object Ask {
     ): Ask[F, A1, B1] = { (msg, timeout, sender) =>
       for {
         b <- self(msg, timeout, sender)
-      } yield for {
-        b <- b
-        b <- f(b)
-      } yield b
+      } yield
+        for {
+          b <- b
+          b <- f(b)
+        } yield b
     }
   }
 

effect-actor/src/test/scala/com/evolution/pekko/effect/actor/ActorVarTest.scala

@@ -80,12 +80,13 @@ class ActorVarTest extends AsyncFunSuite with Matchers {
           actorVar.receive { state0 =>
             for {
               _ <- actions.add(Action.Updated(state0, state))
-            } yield for {
-              state <- state
-            } yield {
-              val release = actions.add(Action.Released(state))
-              Releasable(state, release.some)
-            }
+            } yield
+              for {
+                state <- state
+              } yield {
+                val release = actions.add(Action.Released(state))
+                Releasable(state, release.some)
+              }
           }
         }
       _ <- GenSpawn[F].cede

effect-cluster-sharding/src/test/scala/com/evolution/pekko/effect/cluster/sharding/ClusterShardingLocalTest.scala

@@ -84,25 +84,26 @@ class ClusterShardingLocalTest extends AsyncFunSuite with ActorSuite with Matche
       )
 
       actorEffect = ActorEffect.fromActor[IO](actorRef)
-    } yield for {
-      a <- probe.expect[Int]
-      b <- actorEffect.ask(ShardedMsg("id", 0), 1.second)
-      a <- a
-      _ <- IO(a.msg shouldEqual 0)
-      _ <- IO(a.from.tell(a.msg.toString, ActorRef.noSender))
-      b <- b
-      _ <- IO(b shouldEqual "0")
-      a <- probe.expect[HandOffStopMsg.type]
-      _ <- clusterShardingLocal.rebalance
-      a <- a
-      _ <- IO(a.msg shouldEqual HandOffStopMsg)
-      r <- clusterShardingLocal.clusterSharding.regions
-      _ <- IO(r shouldEqual Set(typeName))
-      s <- clusterShardingLocal.clusterSharding.shards(r.head)
-      _ <- IO(s shouldEqual Set(ShardState("1", Set.empty)))
-      r <- clusterShardingLocal.clusterSharding.shardRegion(typeName)
-      _ <- IO(r shouldEqual actorRef)
-    } yield {}
+    } yield
+      for {
+        a <- probe.expect[Int]
+        b <- actorEffect.ask(ShardedMsg("id", 0), 1.second)
+        a <- a
+        _ <- IO(a.msg shouldEqual 0)
+        _ <- IO(a.from.tell(a.msg.toString, ActorRef.noSender))
+        b <- b
+        _ <- IO(b shouldEqual "0")
+        a <- probe.expect[HandOffStopMsg.type]
+        _ <- clusterShardingLocal.rebalance
+        a <- a
+        _ <- IO(a.msg shouldEqual HandOffStopMsg)
+        r <- clusterShardingLocal.clusterSharding.regions
+        _ <- IO(r shouldEqual Set(typeName))
+        s <- clusterShardingLocal.clusterSharding.shards(r.head)
+        _ <- IO(s shouldEqual Set(ShardState("1", Set.empty)))
+        r <- clusterShardingLocal.clusterSharding.shardRegion(typeName)
+        _ <- IO(r shouldEqual actorRef)
+      } yield {}
 
     result
       .use(identity)

effect-cluster-sharding/src/test/scala/com/evolution/pekko/effect/cluster/sharding/ClusterShardingTest.scala

@@ -56,11 +56,12 @@ class ClusterShardingTest extends AsyncFunSuite with ActorSuite with Matchers {
         new LeastShardAllocationStrategy(1, 1),
         HandOffStopMessage,
       )
-    } yield for {
-      a <- probe.expect[Unit]
-      _ <- IO(shardRegion.tell((), probe.actorEffect.toUnsafe))
-      a <- a
-    } yield a.msg
+    } yield
+      for {
+        a <- probe.expect[Unit]
+        _ <- IO(shardRegion.tell((), probe.actorEffect.toUnsafe))
+        a <- a
+      } yield a.msg
     result
       .use(identity)
       .run()

effect-eventsourcing/src/main/scala/com/evolution/pekko/effect/eventsourcing/Engine.scala

@@ -261,10 +261,11 @@ object Engine {
               d <- Deferred[F, Either[Throwable, A]]
               f <- loadOf(load, d).start
               _ <- offer(f)
-            } yield for {
-              a <- d.get
-              a <- a.liftTo[F]
-            } yield a
+            } yield
+              for {
+                a <- d.get
+                a <- a.liftTo[F]
+              } yield a
         }
       }
       engine <- fenced(engine)
@@ -327,10 +328,11 @@ object Engine {
           fv <- load.start // fork `load` stage to allow multiple independent executions
           fu = execute(fv.joinWithNever, d)
           _ <- queue(Key.validate.some)(fu)
-        } yield for {
-          e <- d.get
-          a <- e.liftTo[F]
-        } yield a
+        } yield
+          for {
+            e <- d.get
+            a <- e.liftTo[F]
+          } yield a
 
       /**
        * Execute `load` with respect to: