diff --git a/net/aws/src/transcriber/imp.rs b/net/aws/src/transcriber/imp.rs index 929fbf41..066dcaeb 100644 --- a/net/aws/src/transcriber/imp.rs +++ b/net/aws/src/transcriber/imp.rs @@ -1719,7 +1719,9 @@ impl TranslateSrcPad { .to_stream_time(state.out_segment.position()) }; - let Some(stream_time) = stream_time else { return false }; + let Some(stream_time) = stream_time else { + return false; + }; q.set(stream_time); true diff --git a/net/aws/src/transcriber/transcribe.rs b/net/aws/src/transcriber/transcribe.rs index e5c27f2f..8c931668 100644 --- a/net/aws/src/transcriber/transcribe.rs +++ b/net/aws/src/transcriber/transcribe.rs @@ -261,7 +261,9 @@ impl TranscriberStream { let discont_offset = self.discont_offset_tracker.lock().unwrap().discont_offset; - let Some(item) = TranscriptItem::from(item, self.lateness, discont_offset) else { continue }; + let Some(item) = TranscriptItem::from(item, self.lateness, discont_offset) else { + continue; + }; gst::debug!( CAT, imp: self.imp, diff --git a/net/webrtc/src/aws_kvs_signaller/imp.rs b/net/webrtc/src/aws_kvs_signaller/imp.rs index 7f55bd03..2623d341 100644 --- a/net/webrtc/src/aws_kvs_signaller/imp.rs +++ b/net/webrtc/src/aws_kvs_signaller/imp.rs @@ -228,7 +228,9 @@ impl Signaller { Ok(credentials) => credentials, }; - let Some(channel_name) = settings.channel_name else { anyhow::bail!("Channel name cannot be None!"); }; + let Some(channel_name) = settings.channel_name else { + anyhow::bail!("Channel name cannot be None!"); + }; let client = Client::new( &aws_config::from_env() @@ -243,11 +245,15 @@ impl Signaller { .send() .await?; - let Some(cinfo) = resp.channel_info() else { anyhow::bail!("No description found for {channel_name}"); }; + let Some(cinfo) = resp.channel_info() else { + anyhow::bail!("No description found for {channel_name}"); + }; gst::debug!(CAT, "Channel description: {cinfo:?}"); - let Some(channel_arn) = cinfo.channel_arn() else { anyhow::bail!("No channel ARN found for {channel_name}"); }; + let Some(channel_arn) = cinfo.channel_arn() else { + anyhow::bail!("No channel ARN found for {channel_name}"); + }; let config = SingleMasterChannelEndpointConfiguration::builder() .set_protocols(Some(vec![ChannelProtocol::Wss, ChannelProtocol::Https])) diff --git a/net/webrtc/src/webrtcsink/imp.rs b/net/webrtc/src/webrtcsink/imp.rs index ddb56590..1a6271d6 100644 --- a/net/webrtc/src/webrtcsink/imp.rs +++ b/net/webrtc/src/webrtcsink/imp.rs @@ -2234,8 +2234,12 @@ impl BaseWebRTCSink { RUNTIME.spawn(async move { while let Some(msg) = bus_stream.next().await { - let Some(element) = element_clone.upgrade() else { break; }; - let Some(pipeline) = pipeline_clone.upgrade() else { break; }; + let Some(element) = element_clone.upgrade() else { + break; + }; + let Some(pipeline) = pipeline_clone.upgrade() else { + break; + }; let this = element.imp(); match msg.view() { gst::MessageView::Error(err) => { @@ -2543,7 +2547,9 @@ impl BaseWebRTCSink { .pad .property::("transceiver"); - let Some(ref stream_name) = webrtc_pad.stream_name else { continue; }; + let Some(ref stream_name) = webrtc_pad.stream_name else { + continue; + }; if let Some(mid) = transceiver.mid() { state.mids.insert(mid.to_string(), stream_name.clone());