diff options
| author | Erik Johnston <erik@matrix.org> | 2018-01-18 11:05:34 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2018-01-18 11:05:34 +0000 |
| commit | 17b54389feb3855a33406149a8a59f0327bb3ad1 (patch) | |
| tree | 8d1b7040a273ac8d0601635fc6bc0657b4f2eece | |
| parent | Move definition of paused_producer to __init__ (diff) | |
| download | synapse-17b54389feb3855a33406149a8a59f0327bb3ad1.tar.xz | |
Fix _notify_empty typo
| -rw-r--r-- | synapse/util/file_consumer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/util/file_consumer.py b/synapse/util/file_consumer.py index 54c9da9573..479e480614 100644 --- 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() |