def parse(self, data):
        self._q.append(data)
        msgs = []
        while True:
            try:
                msg, self._q = self.try_parse(self._q)
            except self.TooSmallException:
                break
            msgs.append(msg)
        return msgs
Tries to extract messages from a raw byte stream.
dataset/ETHPy150Open osrg/ryu/ryu/lib/packet/stream_parser.py/StreamParser.parse