| 68 | self._established.set() |
| 69 | |
| 70 | def receive(self): |
| 71 | log.info("{0} waiting for connection to be established...", self) |
| 72 | if not self._established.wait(timeout=self.TIMEOUT): |
| 73 | log.error("{0} timed out waiting for connection after {1} seconds", self, self.TIMEOUT) |
| 74 | raise TimeoutError(f"{self} timed out waiting for debuggee to connect") |
| 75 | log.info("{0} connection established, reading JSON...", self) |
| 76 | result = self._stream.read_json() |
| 77 | log.info("{0} received: {1}", self, result) |
| 78 | return result |
| 79 | |
| 80 | def send(self, value): |
| 81 | self.session.timeline.unfreeze() |