def run_monitor()

in src/rosbridge/server.py [0:0]

• 10 lines of code
• 4 McCabe index (conditional complexity)

    def run_monitor(self):
        logger.info('zmq gym server listening on monitoring socket')
        while True:
            ev = zmq.utils.monitor.recv_monitor_message(self.monitor_sock)
            logger.debug('Monitor Event %s', ev)
            with self.rpc_lock:
                if ev['event'] == zmq.EVENT_DISCONNECTED:
                    logger.info('zmq disconnect')
                elif ev['event'] == zmq.EVENT_ACCEPTED:
                    logger.info('zmq accept')