Skip to content

Commit 5ea34ff

Browse files
authored
Terminate all entities of each entity type in parallel (#158)
1 parent 9d880e9 commit 5ea34ff

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

entities/src/main/scala/com/devsisters/shardcake/Sharding.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ class Sharding private (
4747
ZIO.logDebug(s"Stopping local entities") *>
4848
isShuttingDownRef.set(true) *>
4949
entityStates.get.flatMap(
50-
ZIO.foreachDiscard(_) { case (name, entity) =>
50+
ZIO.foreachParDiscard(_) { case (name, entity) =>
5151
entity.entityManager.terminateAllEntities.forkDaemon // run in a daemon fiber to make sure it doesn't get interrupted
5252
.flatMap(_.join)
5353
.catchAllCause(ZIO.logErrorCause(s"Error during stop of entity $name", _))

0 commit comments

Comments
 (0)