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:
Diffstat (limited to 'text/json/src/jsongstparse/imp.rs')
-rw-r--r--text/json/src/jsongstparse/imp.rs16
1 files changed, 7 insertions, 9 deletions
diff --git a/text/json/src/jsongstparse/imp.rs b/text/json/src/jsongstparse/imp.rs
index 1e6c48b36..8d9393980 100644
--- a/text/json/src/jsongstparse/imp.rs
+++ b/text/json/src/jsongstparse/imp.rs
@@ -39,9 +39,7 @@ impl PullState {
fn new(imp: &JsonGstParse, pad: &gst::Pad) -> Self {
Self {
need_stream_start: true,
- stream_id: pad
- .create_stream_id(&*imp.instance(), Some("src"))
- .to_string(),
+ stream_id: pad.create_stream_id(&*imp.obj(), Some("src")).to_string(),
offset: 0,
duration: None,
}
@@ -633,14 +631,14 @@ impl JsonGstParse {
self.flush(&mut state);
drop(state);
- gst::Pad::event_default(pad, Some(&*self.instance()), event)
+ gst::Pad::event_default(pad, Some(&*self.obj()), event)
}
EventView::Eos(_) => {
gst::log!(CAT, obj: pad, "Draining");
if let Err(err) = self.handle_buffer(None) {
gst::error!(CAT, obj: pad, "Failed to drain parser: {:?}", err);
}
- gst::Pad::event_default(pad, Some(&*self.instance()), event)
+ gst::Pad::event_default(pad, Some(&*self.obj()), event)
}
_ => {
if event.is_sticky()
@@ -652,7 +650,7 @@ impl JsonGstParse {
state.pending_events.push(event);
true
} else {
- gst::Pad::event_default(pad, Some(&*self.instance()), event)
+ gst::Pad::event_default(pad, Some(&*self.obj()), event)
}
}
}
@@ -757,7 +755,7 @@ impl JsonGstParse {
gst::log!(CAT, obj: pad, "Handling event {:?}", event);
match event.view() {
EventView::Seek(e) => self.perform_seek(e),
- _ => gst::Pad::event_default(pad, Some(&*self.instance()), event),
+ _ => gst::Pad::event_default(pad, Some(&*self.obj()), event),
}
}
@@ -811,7 +809,7 @@ impl JsonGstParse {
self.sinkpad.peer_query(query)
}
}
- _ => gst::Pad::query_default(pad, Some(&*self.instance()), query),
+ _ => gst::Pad::query_default(pad, Some(&*self.obj()), query),
}
}
}
@@ -890,7 +888,7 @@ impl ObjectImpl for JsonGstParse {
fn constructed(&self) {
self.parent_constructed();
- let obj = self.instance();
+ let obj = self.obj();
obj.add_pad(&self.sinkpad).unwrap();
obj.add_pad(&self.srcpad).unwrap();
}