Method _proxy_lines

P2Pro/util.py:6–9

(pipe, handler)

class PipeLogger:
    @staticmethod
    def _proxy_lines(pipe, handler):
        with pipe:
            for line in pipe:
                handler(line.decode(sys.stdout.encoding).rstrip())

    def __init__(self, pipe, handler):
        threading.Thread(target=self._proxy_lines, args=[pipe, handler]).start()