(self, stream)
return shell_output
Launch output reader.
Launch output reader.
Launch output reader .
def _launch_reader_thread(self, stream):
        """Launch output reader."""
        shell_output = deque()
        outp = threading.Thread(target=self._process_stdout, args=(stream, shell_output))
        # daemonise or join later? if we join, a shell that doesn't close will hang us on exit
        outp.daemon = True
        outp.start()
        return shell_output
def _launch_reader_thread ( self , stream ) : shell_output = deque ( ) outp = threading . Thread ( target = self . _process_stdout , args = ( stream , shell_output ) ) # daemonise or join later? if we join, a shell that doesn't close will hang us on exit outp . daemon = True outp . start ( ) return shell_output