Skip to content

Commit 4f1627b

Browse files
Merge branch 'series/2.x' into add-request-metadata
2 parents 4f79abf + 5ea34ff commit 4f1627b

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)