diff options
author | François Laignel <fengalin@free.fr> | 2021-04-20 15:58:11 +0300 |
---|---|---|
committer | François Laignel <fengalin@free.fr> | 2021-04-20 19:19:58 +0300 |
commit | 67c5871957a583c5817156891cb6586a54e6d5f4 (patch) | |
tree | 3d9aff3447876b8d17df180b8a0e9b9594f90b5d /net | |
parent | 27bc5c89cad7dfec9cc12c6c87beca76a4a0b139 (diff) |
fix-getters-calls 0.3.0 pass
Diffstat (limited to 'net')
-rw-r--r-- | net/reqwest/build.rs | 2 | ||||
-rw-r--r-- | net/reqwest/src/reqwesthttpsrc/imp.rs | 10 | ||||
-rw-r--r-- | net/reqwest/tests/reqwesthttpsrc.rs | 14 | ||||
-rw-r--r-- | net/rusoto/build.rs | 2 | ||||
-rw-r--r-- | net/rusoto/src/aws_transcriber/imp.rs | 6 | ||||
-rw-r--r-- | net/rusoto/src/s3src/imp.rs | 2 |
6 files changed, 18 insertions, 18 deletions
diff --git a/net/reqwest/build.rs b/net/reqwest/build.rs index 17be1215e..cda12e57e 100644 --- a/net/reqwest/build.rs +++ b/net/reqwest/build.rs @@ -1,3 +1,3 @@ fn main() { - gst_plugin_version_helper::get_info() + gst_plugin_version_helper::info() } diff --git a/net/reqwest/src/reqwesthttpsrc/imp.rs b/net/reqwest/src/reqwesthttpsrc/imp.rs index 6bb40c8ef..5b67d9958 100644 --- a/net/reqwest/src/reqwesthttpsrc/imp.rs +++ b/net/reqwest/src/reqwesthttpsrc/imp.rs @@ -178,7 +178,7 @@ impl ReqwestHttpSrc { return Ok(client.clone()); } - let srcpad = src.get_static_pad("src").unwrap(); + let srcpad = src.static_pad("src").unwrap(); let mut q = gst::query::Context::new(REQWEST_CLIENT_CONTEXT); if srcpad.peer_query(&mut q) { if let Some(context) = q.context_owned() { @@ -471,15 +471,15 @@ impl ReqwestHttpSrc { gst_debug!(CAT, obj: src, "Got content type {}", content_type); if let Some(ref mut caps) = caps { let caps = caps.get_mut().unwrap(); - let s = caps.get_mut_structure(0).unwrap(); + let s = caps.structure_mut(0).unwrap(); s.set("content-type", &content_type.as_ref()); } else if content_type.type_() == "audio" && content_type.subtype() == "L16" { let channels = content_type - .get_param("channels") + .param("channels") .and_then(|s| s.as_ref().parse::<i32>().ok()) .unwrap_or(2); let rate = content_type - .get_param("rate") + .param("rate") .and_then(|s| s.as_ref().parse::<i32>().ok()) .unwrap_or(44_100); @@ -1014,7 +1014,7 @@ impl PushSrcImpl for ReqwestHttpSrc { if let Some(tags) = tags { gst_debug!(CAT, obj: src, "Sending iradio tags {:?}", tags); - let pad = src.get_static_pad("src").unwrap(); + let pad = src.static_pad("src").unwrap(); pad.push_event(gst::event::Tag::new(tags)); } diff --git a/net/reqwest/tests/reqwesthttpsrc.rs b/net/reqwest/tests/reqwesthttpsrc.rs index 4e51c184d..11cb5d9af 100644 --- a/net/reqwest/tests/reqwesthttpsrc.rs +++ b/net/reqwest/tests/reqwesthttpsrc.rs @@ -81,7 +81,7 @@ impl Harness { }) .build(); - let srcpad = src.get_static_pad("src").unwrap(); + let srcpad = src.static_pad("src").unwrap(); srcpad.link(&pad).unwrap(); let bus = gst::Bus::new(); @@ -459,7 +459,7 @@ fn test_extra_headers() { assert_eq!(headers.get("baz").unwrap(), "1"); assert_eq!( headers - .get_all("list") + .all("list") .iter() .map(|v| v.to_str().unwrap()) .collect::<Vec<&str>>(), @@ -467,7 +467,7 @@ fn test_extra_headers() { ); assert_eq!( headers - .get_all("array") + .all("array") .iter() .map(|v| v.to_str().unwrap()) .collect::<Vec<&str>>(), @@ -640,7 +640,7 @@ fn test_iradio_mode() { // Check if everything was read assert_eq!(cursor.position(), 11); - let srcpad = h.src.get_static_pad("src").unwrap(); + let srcpad = h.src.static_pad("src").unwrap(); let caps = srcpad.current_caps().unwrap(); assert_eq!( caps, @@ -652,7 +652,7 @@ fn test_iradio_mode() { { use gst::EventView; - let tag_event = srcpad.get_sticky_event(gst::EventType::Tag, 0).unwrap(); + let tag_event = srcpad.sticky_event(gst::EventType::Tag, 0).unwrap(); if let EventView::Tag(tags) = tag_event.view() { let tags = tags.tag(); assert_eq!( @@ -721,7 +721,7 @@ fn test_audio_l16() { // Check if everything was read assert_eq!(cursor.position(), 11); - let srcpad = h.src.get_static_pad("src").unwrap(); + let srcpad = h.src.static_pad("src").unwrap(); let caps = srcpad.current_caps().unwrap(); assert_eq!( caps, @@ -1172,7 +1172,7 @@ fn test_cookies() { }, ); - let context = h.src.get_context("gst.reqwest.client").expect("No context"); + let context = h.src.context("gst.reqwest.client").expect("No context"); h2.src.set_context(&context); // Set the HTTP source to Playing so that everything can start diff --git a/net/rusoto/build.rs b/net/rusoto/build.rs index 17be1215e..cda12e57e 100644 --- a/net/rusoto/build.rs +++ b/net/rusoto/build.rs @@ -1,3 +1,3 @@ fn main() { - gst_plugin_version_helper::get_info() + gst_plugin_version_helper::info() } diff --git a/net/rusoto/src/aws_transcriber/imp.rs b/net/rusoto/src/aws_transcriber/imp.rs index a7d7fba82..32015e129 100644 --- a/net/rusoto/src/aws_transcriber/imp.rs +++ b/net/rusoto/src/aws_transcriber/imp.rs @@ -821,7 +821,7 @@ impl Transcriber { } let in_caps = self.sinkpad.current_caps().unwrap(); - let s = in_caps.get_structure(0).unwrap(); + let s = in_caps.structure(0).unwrap(); let sample_rate: i32 = s.get("rate").unwrap().unwrap(); let settings = self.settings.lock().unwrap(); @@ -962,7 +962,7 @@ impl ObjectSubclass for Transcriber { type ParentType = gst::Element; fn with_class(klass: &Self::Class) -> Self { - let templ = klass.get_pad_template("sink").unwrap(); + let templ = klass.pad_template("sink").unwrap(); let sinkpad = gst::Pad::builder_with_template(&templ, Some("sink")) .chain_function(|pad, parent, buffer| { Transcriber::catch_panic_pad_function( @@ -980,7 +980,7 @@ impl ObjectSubclass for Transcriber { }) .build(); - let templ = klass.get_pad_template("src").unwrap(); + let templ = klass.pad_template("src").unwrap(); let srcpad = gst::Pad::builder_with_template(&templ, Some("src")) .activatemode_function(|pad, parent, mode, active| { Transcriber::catch_panic_pad_function( diff --git a/net/rusoto/src/s3src/imp.rs b/net/rusoto/src/s3src/imp.rs index 07cb4ab05..72f328d31 100644 --- a/net/rusoto/src/s3src/imp.rs +++ b/net/rusoto/src/s3src/imp.rs @@ -175,7 +175,7 @@ impl S3Src { offset + length - 1 ); - let response = client.get_object(request); + let response = client.object(request); let output = s3utils::wait(&self.canceller, response).map_err(|err| match err { WaitError::FutureError(err) => Some(gst::error_msg!( |