Semantic improvements in MBoxReader
This commit is contained in:
parent
a6a6d32e79
commit
cfeffa27a4
1 changed files with 6 additions and 3 deletions
|
@ -75,6 +75,7 @@ class MBoxReader():
|
||||||
|
|
||||||
if line is None or line == '':
|
if line is None or line == '':
|
||||||
ret = self.message
|
ret = self.message
|
||||||
|
ret.finish()
|
||||||
|
|
||||||
self.message = None
|
self.message = None
|
||||||
|
|
||||||
|
@ -89,16 +90,18 @@ class MBoxReader():
|
||||||
if self.buf.is_start():
|
if self.buf.is_start():
|
||||||
if self.message is None:
|
if self.message is None:
|
||||||
self.message = Message()
|
self.message = Message()
|
||||||
|
self.message.readline(line)
|
||||||
else:
|
else:
|
||||||
ret = self.message
|
ret = self.message
|
||||||
|
ret.finish()
|
||||||
|
|
||||||
self.message = Message()
|
self.message = Message()
|
||||||
self.message.readline(line)
|
self.message.readline(line)
|
||||||
|
|
||||||
return ret
|
return ret
|
||||||
|
else:
|
||||||
if self.message:
|
if self.message:
|
||||||
self.message.readline(line)
|
self.message.readline(line)
|
||||||
|
|
||||||
def messages(self):
|
def messages(self):
|
||||||
while True:
|
while True:
|
||||||
|
|
Loading…
Add table
Reference in a new issue