(self, echo=False)
| 282 | daemon = True # Don't hang if main thread crashes |
| 283 | started = False |
| 284 | def __init__(self, echo=False): |
| 285 | super(StreamCapturer, self).__init__() |
| 286 | self.echo = echo |
| 287 | self.streams = [] |
| 288 | self.buffer = BytesIO() |
| 289 | self.readfd, self.writefd = os.pipe() |
| 290 | self.buffer_lock = Lock() |
| 291 | self.stop = Event() |
| 292 | |
| 293 | def run(self): |
| 294 | self.started = True |