code: async def handle_forever(self):
          
          while self.connected:
              data = await self.connection.recv()
              if not data:
                  if self.connected:
                      await self.disconnect(expected=False)
                  break
              await self.on_data(data)
docs: Handle data forever.