Some clarifying comments

2020-06-11 15:45:00 +02:00 · 2020-06-11 15:45:00 +02:00 · d2dd80fe17
commit d2dd80fe17
parent 078d7bd2fb
2 changed files with 2 additions and 0 deletions
--- a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala
+++ b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala
@ -247,6 +247,7 @@ private[akka] object Shard {
    private val entities: java.util.Map[EntityId, EntityState] = new util.HashMap[EntityId, EntityState]()
    // needed to look up entity by reg when a Passivating is received
    private val byRef = new util.HashMap[ActorRef, EntityId]()
+    // optimization to not have to go through all entities to find batched writes
    private val remembering = new util.HashSet[EntityId]()

    def alreadyRemembered(set: Set[EntityId]): Unit = {