Lines Matching refs:websocket

163     async def _register_connection(self, websocket) -> None:  argument
165         self._connections.add(websocket)
166         _LOG.info("Client connection established: %s", websocket.id)
175                     self._drop_lost_connection(websocket),
183     async def _drop_lost_connection(self, websocket) -> None:  argument
187         if websocket.closed:
188             self._connections.remove(websocket)
189             _LOG.info("Client connection dropped: %s", websocket.id)
192         _LOG.debug("Client connection heartbeat active: %s", websocket.id)
296 …async with websockets.connect(f"ws://{address}:{port}") as websocket:  # type: ignore # pylint: di…
297         _LOG.info("Connection ID: %s", websocket.id)
298         async for message in websocket: