diff options
| author | Kali Kaneko <kali@leap.se> | 2014-01-24 05:39:13 -0400 |
|---|---|---|
| committer | Kali Kaneko <kali@leap.se> | 2014-01-28 19:38:45 -0400 |
| commit | e02db78b1b6d8fe021efd4adb250c64a1dd4bac4 (patch) | |
| tree | 8837eb90579898f2488dfe7fd581c87dd3a43def /src/leap/mail/messageflow.py | |
| parent | ff28e22977db802c87f0b7be99e37c6de29183e9 (diff) | |
flags use the memstore
* add new/dirty deferred dict to notify when written to disk
* fix eventual duplication after copy
* fix flag flickering on first retrieval.
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): |