async def METHOD_NAME(self, websocket):
    conn = None
    try:
        conn = WsConnection(websocket, self.aio_context, self.connector, self.ssl_context)
        self.add_connection(conn)
        await self._read_loop(conn)
        self.close_connection(conn)
    except ConnectionClosedOK as ex:
        conn_info = str(conn) if conn else "N/A"
        log.debug(f"Connection {conn_info} is closed by peer: {secure_format_exception(ex)}")