code: async def subscriptions(self, request):
          
  
          if not self._accepting:
              return web.Response(status=503)
  
          web_sock = web.WebSocketResponse()
          await web_sock.prepare(request)
  
          async for msg in web_sock:
              if msg.type == aiohttp.WSMsgType.TEXT:
                  await self._handle_message(web_sock, msg.data)
              elif msg.type == aiohttp.WSMsgType.ERROR:
                  LOGGER.warning(
                      'Web socket connection closed with exception %s',
                      web_sock.exception())
                  await web_sock.close()
  
          await self._handle_unsubscribe(web_sock)
  
          return web_sock
docs: Handles requests for new subscription websockets.
  
          Args:
              request (aiohttp.Request): the incoming request
  
          Returns:
              aiohttp.web.WebSocketResponse: the websocket response, when the
                  resulting websocket is closed