def _start_thread()

in torchx/schedulers/streams.py [0:0]

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

    def _start_thread(self) -> None:
        BUFSIZE = 64000
        while True:
            read = False
            for r in self.streams:
                data = r.read(BUFSIZE)
                if data:
                    read = True
                    self.write(data)
            if not read:
                if self._closed:
                    break
                time.sleep(0.1)