Remove spurious break

1 files changed, 0 insertions, 3 deletions

diff --git a/synapse/storage/stream.py b/synapse/storage/stream.py

index b3492d9109..5062bf4e47 100644
--- a/synapse/storage/stream.py
+++ b/synapse/storage/stream.py
@@ -826,9 +826,6 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore):
             txn.execute(sql, args)
             new_rows = [_EventDictReturn(*row) for row in txn]
 
-            if not new_rows:
-                break
-
             rows.extend(new_rows)
 
         if limit > 0: