summaryrefslogtreecommitdiff
path: root/src/leap/mail/imap/memorystore.py
diff options
context:
space:
mode:
authorKali Kaneko <kali@leap.se>2014-02-05 23:44:23 -0400
committerKali Kaneko <kali@leap.se>2014-02-17 11:37:03 -0400
commit06556ec6dc56a4859736fc2782779ee2eb9c1f55 (patch)
treefceb5909a88da9bc185d7474eba6e1ddc50c8fa9 /src/leap/mail/imap/memorystore.py
parentc955c7015b5986af40b2253ac98846f4547e5e00 (diff)
defer parse to thread
Diffstat (limited to 'src/leap/mail/imap/memorystore.py')
-rw-r--r--src/leap/mail/imap/memorystore.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/leap/mail/imap/memorystore.py b/src/leap/mail/imap/memorystore.py
index d0321ae..8deddda 100644
--- a/src/leap/mail/imap/memorystore.py
+++ b/src/leap/mail/imap/memorystore.py
@@ -230,6 +230,8 @@ class MemoryStore(object):
be fired.
:type notify_on_disk: bool
"""
+ from twisted.internet import reactor
+
log.msg("adding new doc to memstore %r (%r)" % (mbox, uid))
key = mbox, uid
@@ -251,7 +253,7 @@ class MemoryStore(object):
if not notify_on_disk:
# Caller does not care, just fired and forgot, so we pass
# a defer that will inmediately have its callback triggered.
- observer.callback(uid)
+ reactor.callLater(0, observer.callback, uid)
def put_message(self, mbox, uid, message, notify_on_disk=True):
"""