(self)
| 64 | accept_thread.start() |
| 65 | |
| 66 | def _setup_stream(self): |
| 67 | self._stream = messaging.JsonIOStream.from_socket(self._socket, name=str(self)) |
| 68 | self._established.set() |
| 69 | |
| 70 | def receive(self): |
| 71 | log.info("{0} waiting for connection to be established...", self) |
no test coverage detected