diff options
author | Sebastian Dröge <sebastian@centricular.com> | 2022-10-23 23:03:22 +0300 |
---|---|---|
committer | Sebastian Dröge <sebastian@centricular.com> | 2022-10-23 23:08:46 +0300 |
commit | 9a68f6e221576f94e153f5f20e499b22745621ec (patch) | |
tree | 776a587d54578bc7dff1fe432bf3008308bffb79 /generic/threadshare/src/jitterbuffer | |
parent | 86776be58c5d7e8607653edcd719ac1f0ba8d992 (diff) |
Move from `imp.instance()` to `imp.obj()`
It's doing the same thing and is shorter.
Diffstat (limited to 'generic/threadshare/src/jitterbuffer')
-rw-r--r-- | generic/threadshare/src/jitterbuffer/imp.rs | 20 |
1 files changed, 7 insertions, 13 deletions
diff --git a/generic/threadshare/src/jitterbuffer/imp.rs b/generic/threadshare/src/jitterbuffer/imp.rs index 5614aae92..44fd54de8 100644 --- a/generic/threadshare/src/jitterbuffer/imp.rs +++ b/generic/threadshare/src/jitterbuffer/imp.rs @@ -341,7 +341,7 @@ impl SinkHandler { pt ); - let element = jb.instance(); + let element = jb.obj(); if dts.is_none() { dts = pts; @@ -523,7 +523,7 @@ impl SinkHandler { // Reschedule if needed let (_, next_wakeup) = jb.src_pad_handler - .next_wakeup(&jb.instance(), &state, latency, context_wait); + .next_wakeup(&jb.obj(), &state, latency, context_wait); if let Some((next_wakeup, _)) = next_wakeup { if let Some((previous_next_wakeup, ref abort_handle)) = state.wait_handle { if previous_next_wakeup.is_none() @@ -1262,11 +1262,7 @@ impl JitterBuffer { self.task .prepare( - JitterBufferTask::new( - &*self.instance(), - &self.src_pad_handler, - &self.sink_pad_handler, - ), + JitterBufferTask::new(&*self.obj(), &self.src_pad_handler, &self.sink_pad_handler), context, ) .block_on()?; @@ -1407,11 +1403,9 @@ impl ObjectImpl for JitterBuffer { let state = self.state.lock().unwrap(); state.jbuf.set_delay(latency); - let _ = self.instance().post_message( - gst::message::Latency::builder() - .src(&*self.instance()) - .build(), - ); + let _ = self + .obj() + .post_message(gst::message::Latency::builder().src(&*self.obj()).build()); } "do-lost" => { let mut settings = self.settings.lock().unwrap(); @@ -1484,7 +1478,7 @@ impl ObjectImpl for JitterBuffer { fn constructed(&self) { self.parent_constructed(); - let obj = self.instance(); + let obj = self.obj(); obj.add_pad(self.sink_pad.gst_pad()).unwrap(); obj.add_pad(self.src_pad.gst_pad()).unwrap(); obj.set_element_flags(gst::ElementFlags::PROVIDE_CLOCK | gst::ElementFlags::REQUIRE_CLOCK); |