def listen(self):
self.validate_listeners()<EOL>with ARBITRATOR.condition:<EOL><INDENT>while self.connected:<EOL><INDENT>ARBITRATOR.condition.wait()<EOL>if not self.run_queues():<EOL><INDENT>break<EOL><DEDENT><DEDENT><DEDENT>
Listen for changes in all registered listeners.