pad.link(q.get_static_pad('sink'))
q.link(conv)
conv.link(sink)
- elif name.startswith('audio'):
- q = Gst.ElementFactory.make('queue')
- conv = Gst.ElementFactory.make('audioconvert')
- resample = Gst.ElementFactory.make('audioresample')
- sink = Gst.ElementFactory.make('autoaudiosink')
- self.pipe.add(q)
- self.pipe.add(conv)
- self.pipe.add(resample)
- self.pipe.add(sink)
- self.pipe.sync_children_states()
- pad.link(q.get_static_pad('sink'))
- q.link(conv)
- conv.link(resample)
- resample.link(sink)
async def listen_to_gstreamer_bus(self):
self.webrtcbin = Gst.ElementFactory.make('webrtcbin', 'laplace')