def connect(self) -> None:
self._socket = socket()
- self._broadcast('CONN_ALERT',
+ self._broadcast(EventType.CONN_ALERT,
f'Connecting to {self._hostname} …')
self._socket.settimeout(TIMEOUT_CONNECT)
try:
self._socket.connect((self._hostname, PORT))
except (TimeoutError, socket_gaierror) as e:
- self._broadcast('CONN_ALERT', str(e))
+ self._broadcast(EventType.CONN_ALERT, str(e))
return
self._socket.settimeout(TIMEOUT_LOOP)
self._assumed_open = True
- self._broadcast('CONNECTED')
+ self._broadcast(EventType.CONNECTED)
self._recv_loop = SocketRecvLoop(self._idx, self._q_to_main,
self._read_lines())