code: async def receiver_handler(websocket):
      runner.addifnew(websocket)
  
      # The commented only works with python3-websockets 4.x
      '''
      async for message in websocket:
          await consumer(websocket, message)
      '''
  
      while True:
          message = await websocket.recv()
          await consumer(websocket, messageync def receiver_handler(websocket):
      runner.addifnew(websocket)
  
      # The commented only works with python3-websockets 4.x
      '''
      async for message in websocket:
          await consumer(websocket, message)
      '''
  
      while True:
          message = await websocket.recv()
          await consumer(websocket, message)
docs: async for message in websocket:
          await consumer(websocket, message)