From 58aadd3dd4fc55899d049e41e789d2828dff668b Mon Sep 17 00:00:00 2001
From: Erik Johnston <erik@matrix.org>
Date: Fri, 1 Jun 2018 11:54:24 +0100
Subject: Remove spurious break

---
 synapse/storage/stream.py | 3 ---
 1 file changed, 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:
-- 
cgit 1.4.1