Merge pull request #442 from patkivikram/vpatki_tombstone

Fix for acking tombstone messages
robinhood · Oct 8, 2019 · 90ec8d5 · 90ec8d5
2 parents 903b110 + b68175b
commit 90ec8d5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/faust/streams.py b/faust/streams.py
@@ -843,7 +843,7 @@ async def _py_aiter(self) -> AsyncIterator:
                 # wait for next message
                 value: Any = None
                 # we iterate until on_merge gives value.
-                while value is None:
+                while value is None and event is None:
                     await sleep(0, loop=loop)
                     # get message from channel
                     # This inlines ThrowableQueue.get for performance: