diff options
Diffstat (limited to 'src/leap/mail/messageflow.py')
| -rw-r--r-- | src/leap/mail/messageflow.py | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/leap/mail/messageflow.py b/src/leap/mail/messageflow.py index ed6abcd..b7fc030 100644 --- a/src/leap/mail/messageflow.py +++ b/src/leap/mail/messageflow.py @@ -126,9 +126,15 @@ class MessageProducer(object): again after the addition of new items. """ self._consumer.consume(self._queue) - if self._queue.empty(): + if self.is_queue_empty(): self.stop() + def is_queue_empty(self): + """ + Return True if queue is empty, False otherwise. + """ + return self._queue.empty() + # public methods: IMessageProducer def push(self, item): |