Use non-streaming cache invalidations in store methods

Author: reivilibre

synapse/storage/databases/main/thread_subscriptions.py

@@ -165,9 +165,8 @@ def _subscribe_user_to_thread_txn(txn: LoggingTransaction) -> Optional[int]:
                 values=values,
             )
 
-            self._invalidate_cache_and_stream(
-                txn,
-                self.get_subscription_for_thread,
+            txn.call_after(
+                self.get_subscription_for_thread.invalidate,
                 (user_id, room_id, thread_root_event_id),
             )
 
@@ -230,9 +229,8 @@ def _unsubscribe_user_from_thread_txn(txn: LoggingTransaction) -> Optional[int]:
                 },
             )
 
-            self._invalidate_cache_and_stream(
-                txn,
-                self.get_subscription_for_thread,
+            txn.call_after(
+                self.get_subscription_for_thread.invalidate,
                 (user_id, room_id, thread_root_event_id),
             )