(self)
| 101 | self.handoffs.append(str(buffer)) |
| 102 | |
| 103 | def playAndIter(self): |
| 104 | self.handoffs = [] |
| 105 | self.pipeline.set_state(gst.STATE_PLAYING) |
| 106 | assert self.pipeline.set_state(gst.STATE_PLAYING) |
| 107 | while 42: |
| 108 | msg = self.bus.pop() |
| 109 | if msg and msg.type == gst.MESSAGE_EOS: |
| 110 | break |
| 111 | assert self.pipeline.set_state(gst.STATE_PAUSED) |
| 112 | handoffs = self.handoffs |
| 113 | self.handoffs = [] |
| 114 | return handoffs |
| 115 | |
| 116 | def sink_seek(self, offset, method=gst.SEEK_TYPE_SET): |
| 117 | self.sink.seek(1.0, gst.FORMAT_BYTES, gst.SEEK_FLAG_FLUSH, |
no outgoing calls
no test coverage detected