def _cbTestPartialAppend(self, fetched, infile):
fetched = list(fetched)
self.assertTrue(len(fetched) == 1)
self.assertTrue(len(fetched[0]) == 2)
uid, msg = fetched[0]
parsed = self.parser.parse(open(infile))
expected_body = parsed.get_payload()
def assert_flags(flags):
self.assertEqual(
set((['\\SEEN'])), set(flags))
def assert_body(body):
gotbody = body.read()
self.assertEqual(expected_body, gotbody)
d = defer.maybeDeferred(msg.getFlags)
d.addCallback(assert_flags)
d.addCallback(lambda _: defer.maybeDeferred(msg.getBodyFile))
d.addCallback(assert_body)
return d
评论列表
文章目录