Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSebastian Dröge <sebastian@centricular.com>2022-10-23 23:03:22 +0300
committerSebastian Dröge <sebastian@centricular.com>2022-10-23 23:08:46 +0300
commit9a68f6e221576f94e153f5f20e499b22745621ec (patch)
tree776a587d54578bc7dff1fe432bf3008308bffb79 /utils/uriplaylistbin
parent86776be58c5d7e8607653edcd719ac1f0ba8d992 (diff)
Move from `imp.instance()` to `imp.obj()`
It's doing the same thing and is shorter.
Diffstat (limited to 'utils/uriplaylistbin')
-rw-r--r--utils/uriplaylistbin/src/uriplaylistbin/imp.rs22
1 files changed, 11 insertions, 11 deletions
diff --git a/utils/uriplaylistbin/src/uriplaylistbin/imp.rs b/utils/uriplaylistbin/src/uriplaylistbin/imp.rs
index 8ee1f4497..fc016e1b2 100644
--- a/utils/uriplaylistbin/src/uriplaylistbin/imp.rs
+++ b/utils/uriplaylistbin/src/uriplaylistbin/imp.rs
@@ -205,7 +205,7 @@ impl State {
// send pending messages then unblock pads
for msg in messages {
- let _ = imp.instance().post_message(msg);
+ let _ = imp.obj().post_message(msg);
}
channels.send(true);
@@ -826,7 +826,7 @@ impl ObjectImpl for UriPlaylistBin {
fn constructed(&self) {
self.parent_constructed();
- let obj = self.instance();
+ let obj = self.obj();
obj.set_suppressed_flags(gst::ElementFlags::SOURCE | gst::ElementFlags::SINK);
obj.set_element_flags(gst::ElementFlags::SOURCE);
}
@@ -978,7 +978,7 @@ impl UriPlaylistBin {
.build()
.map_err(|e| PlaylistError::PluginMissing { error: e.into() })?;
- self.instance().add(&streamsynchronizer).unwrap();
+ self.obj().add(&streamsynchronizer).unwrap();
let settings = self.settings.lock().unwrap();
@@ -1015,7 +1015,7 @@ impl UriPlaylistBin {
let _ = uridecodebin.set_state(gst::State::Null);
});
- self.instance().remove(&uridecodebin).unwrap();
+ self.obj().remove(&uridecodebin).unwrap();
}
if state.waiting_for_stream_collection.is_some()
@@ -1062,7 +1062,7 @@ impl UriPlaylistBin {
let uridecodebin = item.uridecodebin();
- self.instance().add(&uridecodebin).unwrap();
+ self.obj().add(&uridecodebin).unwrap();
let item_clone = item.clone();
assert!(state.waiting_for_stream_collection.is_none());
@@ -1217,7 +1217,7 @@ impl UriPlaylistBin {
}
fn process_decodebin_pad(&self, src_pad: &gst::Pad) {
- let element = self.instance();
+ let element = self.obj();
let start_next = {
let mut state_guard = self.state.lock().unwrap();
@@ -1561,7 +1561,7 @@ impl UriPlaylistBin {
streamsynchronizer.release_request_pad(&ss_sink);
// remove associated ghost pad
- let src_pads = imp.instance().src_pads();
+ let src_pads = imp.obj().src_pads();
let ghost = src_pads
.iter()
.find(|pad| {
@@ -1569,9 +1569,9 @@ impl UriPlaylistBin {
ghost.target().is_none()
})
.unwrap();
- imp.instance().remove_pad(ghost).unwrap();
+ imp.obj().remove_pad(ghost).unwrap();
- imp.instance().remove(&concat).unwrap();
+ imp.obj().remove(&concat).unwrap();
let _ = concat.set_state(gst::State::Null);
}
}
@@ -1636,7 +1636,7 @@ impl UriPlaylistBin {
uridecodebin.call_async(move |uridecodebin| {
let _ = uridecodebin.set_state(gst::State::Null);
});
- let _ = self.instance().remove(&uridecodebin);
+ let _ = self.obj().remove(&uridecodebin);
let details = gst::Structure::builder("details");
let details = details.field("uri", item.uri());
@@ -1672,7 +1672,7 @@ impl UriPlaylistBin {
current_iteration = 0;
}
- let element = self.instance();
+ let element = self.obj();
if current_iteration != state.current_iteration {
state.current_iteration = current_iteration;
element.notify("current-iteration");