Fix _notify_empty typo

7 years ago · 17b54389fe
parent 28b338ed9b
commit 17b54389fe
1 changed files with 1 additions and 1 deletions
--- a/synapse/util/file_consumer.py
+++ b/synapse/util/file_consumer.py
@ -110,7 +110,7 @@ class BackgroundFileConsumer(object):
                    if self.bytes_queue.qsize() <= self._RESUME_ON_QUEUE_SIZE:
                        reactor.callFromThread(self._resume_paused_producer)

-                if self._notify_empty and self.bytes_queue.empty():
+                if self._notify_empty_deferred and self.bytes_queue.empty():
                    reactor.callFromThread(self._notify_empty)

                bytes = self.bytes_queue.get()