code: async def handler(self):
      '''Handle loop, get and process messages'''
      self.ws = await websockets.connect(self.url, ssl=self.ssl)
      while self.ws:
        message = await self.ws.recv()
        for handle in self.on_message:
          if asyncio.iscoroutinefunction(handle):
            await handle(self, message)
          else:
            handle(self, messageync def handler(self):
      '''Handle loop, get and process messages'''
      self.ws = await websockets.connect(self.url, ssl=self.ssl)
      while self.ws:
        message = await self.ws.recv()
        for handle in self.on_message:
          if asyncio.iscoroutinefunction(handle):
            await handle(self, message)
          else:
            handle(self, message)
docs: Handle loop, get and process messages