(self, main_window)
| 474 | self.emit('done', response) |
| 475 | |
| 476 | def start(self, main_window): |
| 477 | self.window = main_window |
| 478 | self.touri = self.do_get_touri() |
| 479 | if not self.touri: |
| 480 | return False |
| 481 | self.do_setup_pipeline() |
| 482 | bus = self.get_bus() |
| 483 | bus.add_signal_watch() |
| 484 | bus.connect('message', self._bus_watch) |
| 485 | if self.window: |
| 486 | # can be None if we are debugging... |
| 487 | self.window.set_sensitive(False) |
| 488 | fromname = self.fromuri.split('/')[-1] |
| 489 | toname = self.touri.split('/')[-1] |
| 490 | self.pdialog = RemuxProgressDialog(main_window, fromname, toname) |
| 491 | self.pdialog.show() |
| 492 | self.pdialog.connect('response', lambda w, r: self.response(r)) |
| 493 | |
| 494 | self.set_state(gst.STATE_PAUSED) |
| 495 | return True |
| 496 | |
| 497 | def run(self, main_window): |
| 498 | if self.start(main_window): |
no test coverage detected