Use efficient .intersection

synapse/util/caches/stream_change_cache.py

@@ -80,10 +80,7 @@ class StreamChangeCache(object):
                 )
             }
 
-            result = {
+            result = changed_entities.intersection(entities)
-                e for e in entities
-                if e in changed_entities
-            }
 
             self.metrics.inc_hits()
         else: