docs: def listen(self):
          """Listen for changes in all registered listeners."""
  
          self.validate_listeners()
          with ARBITRATOR.condition:
              while self.connected:
                  ARBITRATOR.condition.wait()
                  if not self.run_queues():
                      break