diff options
| author | Sebastian Dröge <sebastian@centricular.com> | 2020-06-30 23:57:22 +0300 |
|---|---|---|
| committer | Sebastian Dröge <slomo@coaxion.net> | 2020-07-01 00:28:02 +0300 |
| commit | a28455f0ce221558ce56ac0507cf437d8418db8a (patch) | |
| tree | e5f6755c0d72d68696ce72ccbec7e963838ed76e /net | |
| parent | e2f27e77cefef85c767d8c3bc6817ee6c1596ba6 (diff) | |
Update for Element::post_message() signature change
Diffstat (limited to 'net')
| -rw-r--r-- | net/reqwest/src/reqwesthttpsrc.rs | 8 | ||||
| -rw-r--r-- | net/rusoto/src/aws_transcribe_parse.rs | 4 | ||||
| -rw-r--r-- | net/rusoto/src/s3sink.rs | 2 |
3 files changed, 7 insertions, 7 deletions
diff --git a/net/reqwest/src/reqwesthttpsrc.rs b/net/reqwest/src/reqwesthttpsrc.rs index fd22f49e0..c76bd5561 100644 --- a/net/reqwest/src/reqwesthttpsrc.rs +++ b/net/reqwest/src/reqwesthttpsrc.rs @@ -283,7 +283,7 @@ impl ReqwestHttpSrc { } } else { let _ = src.post_message( - &gst::message::NeedContext::builder(REQWEST_CLIENT_CONTEXT) + gst::message::NeedContext::builder(REQWEST_CLIENT_CONTEXT) .src(src) .build(), ); @@ -325,7 +325,7 @@ impl ReqwestHttpSrc { s.set("client", &client); } src.set_context(&context); - let _ = src.post_message(&gst::message::HaveContext::builder(context).src(src).build()); + let _ = src.post_message(gst::message::HaveContext::builder(context).src(src).build()); *client_guard = Some(client.clone()); @@ -944,7 +944,7 @@ impl BaseSrcImpl for ReqwestHttpSrc { true } Err(Some(err)) => { - src.post_error_message(&err); + src.post_error_message(err); false } Err(None) => false, @@ -1013,7 +1013,7 @@ impl PushSrcImpl for ReqwestHttpSrc { Ok(res) => res, Err(Some(err)) => { gst_debug!(CAT, obj: src, "Error {:?}", err); - src.post_error_message(&err); + src.post_error_message(err); return Err(gst::FlowError::Error); } Err(None) => { diff --git a/net/rusoto/src/aws_transcribe_parse.rs b/net/rusoto/src/aws_transcribe_parse.rs index 91effefe9..5fb161fa0 100644 --- a/net/rusoto/src/aws_transcribe_parse.rs +++ b/net/rusoto/src/aws_transcribe_parse.rs @@ -681,7 +681,7 @@ impl Transcriber { gst_info!(CAT, obj: element, "Received flush start, disconnecting"); match self.disconnect(element) { Err(err) => { - element.post_error_message(&err); + element.post_error_message(err); false } Ok(_) => { @@ -1149,7 +1149,7 @@ impl ElementImpl for Transcriber { match transition { gst::StateChange::PausedToReady => { self.disconnect(element).map_err(|err| { - element.post_error_message(&err); + element.post_error_message(err); gst::StateChangeError })?; } diff --git a/net/rusoto/src/s3sink.rs b/net/rusoto/src/s3sink.rs index 33fc6331d..74b4d2fd2 100644 --- a/net/rusoto/src/s3sink.rs +++ b/net/rusoto/src/s3sink.rs @@ -502,7 +502,7 @@ impl BaseSinkImpl for S3Sink { "Multipart upload failed: {}", error_message ); - element.post_error_message(&error_message); + element.post_error_message(error_message); Err(gst::FlowError::Error) } _ => { |