run scalafmt

devsisters · May 31, 2024 · 5ce32fe · 5ce32fe
1 parent 2f9c988
commit 5ce32fe
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 7 deletions.
diff --git a/benchmarks/src/main/scala/com/devsisters/shardcake/Client.scala b/benchmarks/src/main/scala/com/devsisters/shardcake/Client.scala
@@ -2,7 +2,7 @@ package com.devsisters.shardcake
 
 import com.devsisters.shardcake.Server.Message.Ping
 import com.devsisters.shardcake.Server.PingPongEntity
-import zio.{Config => _, _}
+import zio.{ Config => _, _ }
 
 object Client {
   // self host should not be `localhost` to avoid optimization

diff --git a/benchmarks/src/main/scala/com/devsisters/shardcake/Server.scala b/benchmarks/src/main/scala/com/devsisters/shardcake/Server.scala
@@ -1,7 +1,7 @@
 package com.devsisters.shardcake
 
 import com.devsisters.shardcake.interfaces.Storage
-import zio.{Config => _, _}
+import zio.{ Config => _, _ }
 import zio.stream.ZStream
 
 import java.util.concurrent.ForkJoinPool

diff --git a/entities/src/main/scala/com/devsisters/shardcake/Sharding.scala b/entities/src/main/scala/com/devsisters/shardcake/Sharding.scala
@@ -337,7 +337,8 @@ class Sharding private (
         }
 
       def sendStream(entityId: String)(messages: ZStream[Any, Throwable, Msg]): Task[Unit] = {
-        val send = ReplyChannel.single[Unit].flatMap[Any, Throwable, Unit](sendStreamGeneric(entityId, messages, None, _))
+        val send =
+          ReplyChannel.single[Unit].flatMap[Any, Throwable, Unit](sendStreamGeneric(entityId, messages, None, _))
         timeout.fold(send)(t => send.timeout(t).unit)
       }
 

diff --git a/entities/src/main/scala/com/devsisters/shardcake/internal/ReplyChannel.scala b/entities/src/main/scala/com/devsisters/shardcake/internal/ReplyChannel.scala
@@ -31,11 +31,13 @@ private[shardcake] object ReplyChannel {
     def fail(cause: Cause[Throwable]): UIO[Unit]                   = promise.failCause(cause).unit
     def replySingle(a: A): UIO[Unit]                               = promise.succeed(Some(a)).unit
     def replyStream(stream: ZStream[Any, Throwable, A]): UIO[Unit] =
-      stream.runHead.flatMap(promise.succeed(_).unit)
+      stream.runHead
+        .flatMap(promise.succeed(_).unit)
         .catchAllCause[Any, Nothing, Unit](fail)
-        .fork.unit
+        .fork
+        .unit
 
-    val output: Task[Option[A]]                                    = promise.await.onError(fail)
+    val output: Task[Option[A]] = promise.await.onError(fail)
   }
 
   def single[A]: UIO[FromPromise[A]] =

diff --git a/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala b/manager/src/main/scala/com/devsisters/shardcake/ShardManager.scala
@@ -317,7 +317,9 @@ object ShardManager {
   ): (Map[PodAddress, Set[ShardId]], Map[PodAddress, Set[ShardId]]) = {
     val (_, assignments)    = shardsToRebalance.foldLeft((state.shardsPerPod, List.empty[(ShardId, PodAddress)])) {
       case ((shardsPerPod, assignments), shard) =>
-        val unassignedPods = assignments.flatMap { case (shard, _) => state.shards.get(shard).flatten[PodAddress] }.toSet
+        val unassignedPods = assignments.flatMap { case (shard, _) =>
+          state.shards.get(shard).flatten[PodAddress]
+        }.toSet
         // find pod with least amount of shards
         shardsPerPod
           // keep only pods with the max version