def METHOD_NAME(self, data):
    if self._pid is None:
        pid_data = data[:8]
        version = _uint64_unpacker(data[8:16])[0]
        data = data[16:]
        self._pid = _uint64_unpacker(pid_data)[0]
        self._on_pid(self, self._transport, self._pid, version)
    for msg in self._stream.feed_data(data):
        self.process_message(msg)