Fix compilation for Scala 2.12

devsisters · Oct 17, 2024 · 3c8860e · 3c8860e
1 parent 088f22f
commit 3c8860e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/entities/src/main/scala/com/devsisters/shardcake/Sharding.scala b/entities/src/main/scala/com/devsisters/shardcake/Sharding.scala
@@ -131,7 +131,9 @@ class Sharding private (
     shardAssignments.get
 
   val thisPodAssignments: UIO[Chunk[ShardId]] =
-    getAssignments.map(_.view.collect { case (shardId, addr) if addr == this.address => shardId }.to(Chunk))
+    getAssignments.map(a =>
+      Chunk.fromIterable(a.view.collect { case (shardId, addr) if addr == this.address => shardId })
+    )
 
   val getPods: UIO[Set[PodAddress]] =
     shardAssignments.get.map(_.values.toSet)