Make terminateAllEntities interruptible so that time out works well (#161)

ghostdogpr · web-flow · commit 2eb50b619b9f · 2025-05-07T09:47:44.000+09:00
diff --git a/entities/src/main/scala/com/devsisters/shardcake/Sharding.scala b/entities/src/main/scala/com/devsisters/shardcake/Sharding.scala
@@ -47,7 +47,7 @@ class Sharding private (
         isShuttingDownRef.set(true) *>
         entityStates.get.flatMap(
           ZIO.foreachParDiscard(_) { case (name, entity) =>
-            entity.entityManager.terminateAllEntities.forkDaemon // run in a daemon fiber to make sure it doesn't get interrupted
+            entity.entityManager.terminateAllEntities.interruptible.forkDaemon // run in a daemon fiber to make sure it doesn't get interrupted
               .flatMap(_.join)
               .catchAllCause(ZIO.logErrorCause(s"Error during stop of entity $name", _))
           }

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ class Sharding private (`
`47`	`47`	`isShuttingDownRef.set(true) *>`
`48`	`48`	`entityStates.get.flatMap(`
`49`	`49`	`ZIO.foreachParDiscard(_) { case (name, entity) =>`
`50`		`- entity.entityManager.terminateAllEntities.forkDaemon // run in a daemon fiber to make sure it doesn't get interrupted`
	`50`	`+ entity.entityManager.terminateAllEntities.interruptible.forkDaemon // run in a daemon fiber to make sure it doesn't get interrupted`
`51`	`51`	`.flatMap(_.join)`
`52`	`52`	`.catchAllCause(ZIO.logErrorCause(s"Error during stop of entity $name", _))`
`53`	`53`	`}`