Update scalafmt-core to 3.10.2 (#438)

## About this PR
📦 Updates
[org.scalameta:scalafmt-core](https://github.com/scalameta/scalafmt)
from `3.10.1` to `3.10.2`

📜 [GitHub Release
Notes](https://github.com/scalameta/scalafmt/releases/tag/v3.10.2) -
[Version
Diff](scalameta/scalafmt@v3.10.1...v3.10.2)

## Usage
✅ **Please merge!**

I'll automatically update this PR to resolve conflicts as long as you
don't change it yourself.

If you'd like to skip this version, you can just close this PR. If you
have any feedback, just mention me in the comments below.

Configure Scala Steward for your repository with a
[`.scala-steward.conf`](https://github.com/scala-steward-org/scala-steward/blob/aa5f323f89a14438111266f586018b68db1de989/docs/repo-specific-configuration.md)
file.

_Have a fantastic day writing Scala!_

<details>
<summary>🔍 Files still referring to the old version number</summary>

The following files still refer to the old version number (3.10.1).
You might want to review and update them manually.
```
.git-blame-ignore-revs
```
</details>
<details>
<summary>⚙ Adjust future updates</summary>

Add this to your `.scala-steward.conf` file to ignore future updates of
this dependency:
```
updates.ignore = [ { groupId = "org.scalameta", artifactId = "scalafmt-core" } ]
```
Or, add this to slow down future updates of this dependency:
```
dependencyOverrides = [{
  pullRequests = { frequency = "30 days" },
  dependency = { groupId = "org.scalameta", artifactId = "scalafmt-core" }
}]
```
</details>

<sup>
labels: library-update, early-semver-patch, semver-spec-patch,
old-version-remains, commit-count:n:3
</sup>

<!-- scala-steward = {
  "Update" : {
    "ForArtifactId" : {
      "crossDependency" : [
        {
          "groupId" : "org.scalameta",
          "artifactId" : {
            "name" : "scalafmt-core",
            "maybeCrossName" : "scalafmt-core_2.13"
          },
          "version" : "3.10.1",
          "sbtVersion" : null,
          "scalaVersion" : null,
          "configurations" : null
        }
      ],
      "newerVersions" : [
        "3.10.2"
      ],
      "newerGroupId" : null,
      "newerArtifactId" : null
    }
  },
  "Labels" : [
    "library-update",
    "early-semver-patch",
    "semver-spec-patch",
    "old-version-remains",
    "commit-count:n:3"
  ]
} -->

Author: scala-steward

.git-blame-ignore-revs

@@ -6,3 +6,6 @@
 
 # Scala Steward: Reformat with scalafmt 3.10.1
 e20c58d38034869ac908a00d87dbb975f2cac2cc
+
+# Scala Steward: Reformat with scalafmt 3.10.2
+097d85055d194076e79b37dac018093ab252efe0

.scalafmt.conf

@@ -1,4 +1,4 @@
-version = 3.10.1
+version = 3.10.2
 
 maxColumn = 120
 

actor-tests/src/test/scala/com/evolutiongaming/akkaeffect/CounterSpec.scala

@@ -95,9 +95,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

actor/src/main/scala/com/evolutiongaming/akkaeffect/Ask.scala

@@ -99,19 +99,21 @@ 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](f: B => F[B1])(implicit F: FlatMap[F]): 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
     }
   }
 

actor/src/test/scala/com/evolutiongaming/akkaeffect/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

cluster-sharding/src/test/scala/com/evolutiongaming/akkaeffect/cluster/sharding/ClusterShardingLocalTest.scala

@@ -83,25 +83,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)

cluster-sharding/src/test/scala/com/evolutiongaming/akkaeffect/cluster/sharding/ClusterShardingTest.scala

@@ -55,11 +55,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()

eventsourcing/src/main/scala/com/evolutiongaming/akkaeffect/eventsourcing/Engine.scala

@@ -252,10 +252,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)
@@ -312,10 +313,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:
         *   1. failure on `load` or `validate` will be propagated to user 2. stopped Engine will not persist any events

eventsourcing/src/main/scala/com/evolutiongaming/akkaeffect/eventsourcing/Journaller.scala

@@ -39,10 +39,11 @@ object Journaller {
       for {
         d <- MeasureDuration[F].start
         r <- self.deleteTo(seqNr)
-      } yield for {
-        r <- r
-        d <- d
-        _ <- log.info(s"delete events to $seqNr in ${d.toMillis}ms")
-      } yield r
+      } yield
+        for {
+          r <- r
+          d <- d
+          _ <- log.info(s"delete events to $seqNr in ${d.toMillis}ms")
+        } yield r
   }
 }

persistence/src/main/scala/com/evolutiongaming/akkaeffect/persistence/Append.scala

@@ -137,11 +137,12 @@ object Append {
       for {
         d <- MeasureDuration[F].start
         r <- self(events)
-      } yield for {
-        r <- r
-        d <- d
-        _ <- log.debug(s"append ${events.size} events in ${d.toMillis}ms")
-      } yield r
+      } yield
+        for {
+          r <- r
+          d <- d
+          _ <- log.debug(s"append ${events.size} events in ${d.toMillis}ms")
+        } yield r
 
     def withFail(fail: Fail[F])(implicit F: MonadThrowable[F]): Append[F, A] = { events =>
       fail.adapt(s"failed to append $events")(self(events))