def run_main()

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

• 8 lines of code
• 2 McCabe index (conditional complexity)

    def run_main(self):
        logger.info('zmq gym server running on %s', self.url)
        while True:
            rx = self.sock.recv_multipart(flags=0, copy=True, track=False)
            logger.debug('%s > %s', self.url, rx[0])
            rpc = zmq_serialize.load_msg(rx)
            with self.rpc_lock:
                self.handle_rpc(rpc)