home *** CD-ROM | disk | FTP | other *** search
- # Source Generated with Decompyle++
- # File: in.pyc (Python 2.6)
-
- __docformat__ = 'restructuredtext en'
- from killableprocess import Popen, PIPE
- from threading import Thread
- from time import sleep
- import os
-
- class PipedProcess(Thread):
-
- def __init__(self, command_string, out_callback, end_callback = None):
- self.command_string = command_string
- self.out_callback = out_callback
- self.end_callback = end_callback
- Thread.__init__(self)
-
-
- def run(self):
- env = os.environ
- env['TERM'] = 'xterm'
- process = Popen(self.command_string + ' 2>&1', shell = True, env = env, universal_newlines = True, stdout = PIPE, stdin = PIPE)
- self.process = process
- while True:
- out_char = process.stdout.read(1)
- if out_char == '':
- if process.poll() is not None:
- break
- else:
- sleep(0.1)
- process.poll() is not None
- self.out_callback(out_char)
- if self.end_callback is not None:
- self.end_callback()
-
-
-
-