Method read_msg

tests/test_jyserver.py:119–129

(self)

        return t, sock

    def read_msg(self):
        msg = "@@PROCESSING_END@@"
        while msg.startswith("@@PROCESSING"):
            msg = self.socket.recv(1024)
            if msg.startswith("@@PROCESSING:"):
                dbg("Status msg:" + str(msg))

        while msg.find("END@@") == -1:
            msg += self.socket.recv(1024)

        return msg

    def send_kill_msg(self, socket):
        socket.send(pycompletionserver.MSG_KILL_SERVER)