diff options
Diffstat (limited to 'generic/threadshare/src/udpsink/imp.rs')
| -rw-r--r-- | generic/threadshare/src/udpsink/imp.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/generic/threadshare/src/udpsink/imp.rs b/generic/threadshare/src/udpsink/imp.rs index a3e1bb96..bb1825d0 100644 --- a/generic/threadshare/src/udpsink/imp.rs +++ b/generic/threadshare/src/udpsink/imp.rs @@ -840,7 +840,7 @@ impl UdpSink { // Enable backpressure for items let (item_sender, item_receiver) = flume::bounded(0); let (cmd_sender, cmd_receiver) = flume::unbounded(); - let task_impl = UdpSinkTask::new(&*self.instance(), item_receiver, cmd_receiver); + let task_impl = UdpSinkTask::new(&*self.obj(), item_receiver, cmd_receiver); self.task.prepare(task_impl, context).block_on()?; *self.item_sender.lock().unwrap() = Some(item_sender); @@ -1248,7 +1248,7 @@ impl ObjectImpl for UdpSink { fn constructed(&self) { self.parent_constructed(); - let obj = self.instance(); + let obj = self.obj(); obj.add_pad(self.sink_pad.gst_pad()).unwrap(); obj.set_element_flags(gst::ElementFlags::SINK); } |