(self, host="localhost", port=50001)
| 41 | self._reconnect = True |
| 42 | |
| 43 | def connect(self, host="localhost", port=50001): |
| 44 | self._host = host |
| 45 | self._port = port |
| 46 | self._reconnect = True |
| 47 | if self._thread and self._thread.is_alive(): |
| 48 | return |
| 49 | self._thread = threading.Thread(target=self._run, daemon=True) |
| 50 | self._thread.start() |
| 51 | |
| 52 | def disconnect(self): |
| 53 | self._reconnect = False |
no test coverage detected