@ -548,6 +548,9 @@ class MessageIterator(object):
if not len(self._buffer):
self.fill()
raise StopIteration
if self.bulk:
res = self._buffer
self._buffer = []