(self)
| 57 | return t, s |
| 58 | |
| 59 | def read_msg(self): |
| 60 | finish = False |
| 61 | msg = "" |
| 62 | while finish == False: |
| 63 | m = self.socket.recv(1024 * 4) |
| 64 | m = m.decode("utf-8") |
| 65 | if m.startswith("@@PROCESSING"): |
| 66 | sys.stdout.write("Status msg: %s\n" % (msg,)) |
| 67 | else: |
| 68 | msg += m |
| 69 | |
| 70 | if msg.find("END@@") != -1: |
| 71 | finish = True |
| 72 | |
| 73 | return msg |
| 74 | |
| 75 | @unittest.skipIf(IS_PY313_OR_GREATER and sys.platform == "linux", "Flakey on Linux") |
| 76 | def test_completion_sockets_and_messages(self): |
no test coverage detected