

def run(self):
    _logger.info('starting RequestHandler')
    while True:
        try:
            item = self.server.requests.get(timeout=0.1)
            if (item.get('_internal') == _SIGNAL_STOP):
                _logger.info('RequestHandler is exiting by internal request')
                return
            self.server.write(item)
        except queue.Empty:
            pass
        except Exception as e:
            msg = (('error in thread ' + self.name) + '\n')
            msg += str(e)
            _logger.error(msg)

dataset/ETHPy150Open guillermooo/dart-sublime-bundle/lib/analyzer/analyzer.py RequestHandler.run/original