code: async def echo_all(app, message):
      
      # Loop through all registered server addresses
      for address in app.kv.get_prefix('address.').values():
          # Parse the host and port from the stored address
          host, port = address.decode().split(':')
          port = int(port)
  
          # Send the message to the echo server
          await tcp_echo_client(message, loop, host, port)
docs: Send and recieve a message from all running echo servers