(self)
| 74 | return pipeline.iterate() |
| 75 | |
| 76 | def test(self): |
| 77 | self.bus = self.pipeline.get_bus() |
| 78 | |
| 79 | self.start = time.time() |
| 80 | |
| 81 | self.pipeline.set_state(gst.STATE_PLAYING) |
| 82 | |
| 83 | while 1: |
| 84 | msg = self.bus.poll(gst.MESSAGE_EOS | gst.MESSAGE_ERROR, gst.SECOND) |
| 85 | if msg: |
| 86 | break |
| 87 | |
| 88 | self.pipeline.set_state(gst.STATE_NULL) |
| 89 | self.done() |
| 90 | |
| 91 | def run(self, buffers): |
| 92 | self.buffers = buffers |