def run()

in zktraffic/cli/printer.py [0:0]

• 12 lines of code
• 6 McCabe index (conditional complexity)

  def run(self):
    self._stopped = False

    while not self._wants_stopped:
      try:
        msg = self._queue.popleft()
        if not self._skip_print or not self._skip_print(msg):
          self._print(msg)
      except IndexError:
        time.sleep(0.1)
      except IOError:  # PIPE broken, most likely
        break

    self._stopped = True