Using flatMap for some reason causes the stream operation to keep entries in memory for all entries that map to a given lock. We should have these processed by address counter instead.