@classmethod
    def parse_stream(cls, iterable):
        parser = Parser()
        for message_dict in iterable:
            completed, parser = parser.add(message_dict)
            for task in completed:
                yield task
        for task in parser.incomplete_tasks():
            yield task
Parse a stream of messages into a stream of L{Task} instances.
dataset/ETHPy150Open ClusterHQ/eliot/eliot/_parse.py/Parser.parse_stream