Method _drain

component-tests/util.py:39–42

()

    @staticmethod
    def _start_reader(pipe, sink):
        def _drain():
            for line in pipe:
                sink.append(line)
            pipe.close()
        t = threading.Thread(target=_drain, daemon=True)
        t.start()
        return t