code: def main(url):
      
      try:
          listener = ListenerWorker(url)
          listener.connect()
          listener.run_forever()
      except KeyboardInterrupt:
          listener.close()
docs: Create, connect, and block on the listener worker.