diff --git a/audio/lewton/src/lewtondec/imp.rs b/audio/lewton/src/lewtondec/imp.rs index ae8d81ff..77851075 100644 --- a/audio/lewton/src/lewtondec/imp.rs +++ b/audio/lewton/src/lewtondec/imp.rs @@ -132,7 +132,7 @@ impl AudioDecoderImpl for LewtonDec { reorder_map: None, }); - let mut state = state_guard.as_mut().unwrap(); + let state = state_guard.as_mut().unwrap(); let s = caps.structure(0).unwrap(); if let Ok(Some(streamheaders)) = s.get_optional::("streamheader") { diff --git a/net/webrtc/src/webrtcsink/imp.rs b/net/webrtc/src/webrtcsink/imp.rs index d0f578e4..e6d13048 100644 --- a/net/webrtc/src/webrtcsink/imp.rs +++ b/net/webrtc/src/webrtcsink/imp.rs @@ -2943,7 +2943,7 @@ impl BaseWebRTCSink { } let mut state = element.imp().state.lock().unwrap(); - if let Some(mut stream) = state.streams.get_mut(&name) { + if let Some(stream) = state.streams.get_mut(&name) { stream.out_caps = Some(payloader_caps.clone()); } @@ -2997,7 +2997,7 @@ impl BaseWebRTCSink { .unwrap() .streams .iter_mut() - .for_each(|(_, mut stream)| { + .for_each(|(_, stream)| { if stream.sink_pad.upcast_ref::() == pad { stream.in_caps = Some(e.caps().to_owned()); } diff --git a/text/json/src/jsongstparse/imp.rs b/text/json/src/jsongstparse/imp.rs index 0d48277b..2f6f9577 100644 --- a/text/json/src/jsongstparse/imp.rs +++ b/text/json/src/jsongstparse/imp.rs @@ -507,7 +507,7 @@ impl JsonGstParse { fn loop_fn(&self) { let mut state = self.state.lock().unwrap(); let State { ref mut pull, .. } = *state; - let mut pull = pull.as_mut().unwrap(); + let pull = pull.as_mut().unwrap(); let offset = pull.offset; let scan_duration = pull.duration.is_none(); @@ -519,7 +519,7 @@ impl JsonGstParse { match self.scan_duration() { Ok(pts) => { let mut state = self.state.lock().unwrap(); - let mut pull = state.pull.as_mut().unwrap(); + let pull = state.pull.as_mut().unwrap(); pull.duration = pts; } Err(err) => { @@ -596,7 +596,7 @@ impl JsonGstParse { self.handle_buffer(Some(buffer)) } - fn flush(&self, mut state: &mut State) { + fn flush(&self, state: &mut State) { state.reader.clear(); if let Some(pull) = &mut state.pull { pull.offset = 0; diff --git a/utils/fallbackswitch/src/fallbacksrc/imp.rs b/utils/fallbackswitch/src/fallbacksrc/imp.rs index acb4e47e..745ad849 100644 --- a/utils/fallbackswitch/src/fallbacksrc/imp.rs +++ b/utils/fallbackswitch/src/fallbacksrc/imp.rs @@ -1441,7 +1441,7 @@ impl FallbackSrc { None => return, }; - let mut source = if fallback_source { + let source = if fallback_source { if let Some(ref mut source) = state.fallback_source { source } else { diff --git a/video/closedcaption/src/jsontovtt/imp.rs b/video/closedcaption/src/jsontovtt/imp.rs index b74510ad..3f096574 100644 --- a/video/closedcaption/src/jsontovtt/imp.rs +++ b/video/closedcaption/src/jsontovtt/imp.rs @@ -205,7 +205,7 @@ impl State { /* Collect cues, fixing up their duration based on the next cue */ while let Some(lines) = self.pending.front() { - if let Some(mut drained_line) = drained_lines.back_mut() { + if let Some(drained_line) = drained_lines.back_mut() { drained_line.duration = lines.pts - drained_line.pts; } @@ -219,7 +219,7 @@ impl State { } /* cues that end a fragment must be clipped and cloned for the next fragment */ - if let Some(mut drained_line) = drained_lines.back_mut() { + if let Some(drained_line) = drained_lines.back_mut() { /* Clip to either the requested PTS, or segment stop if specified */ let end_pts = if running_time.is_none() { self.last_pts.unwrap() diff --git a/video/closedcaption/src/mcc_parse/imp.rs b/video/closedcaption/src/mcc_parse/imp.rs index 130d3938..11c57e72 100644 --- a/video/closedcaption/src/mcc_parse/imp.rs +++ b/video/closedcaption/src/mcc_parse/imp.rs @@ -725,7 +725,7 @@ impl MccParse { ref mut pull, .. } = *state; - let mut pull = pull.as_mut().unwrap(); + let pull = pull.as_mut().unwrap(); let scan_tc_rate = tc_rate.is_none() && pull.duration.is_none(); let offset = pull.offset; @@ -763,12 +763,12 @@ impl MccParse { match self.scan_duration() { Ok(Some(tc)) => { let mut state = self.state.lock().unwrap(); - let mut pull = state.pull.as_mut().unwrap(); + let pull = state.pull.as_mut().unwrap(); pull.duration = Some(tc.time_since_daily_jam()); } Ok(None) => { let mut state = self.state.lock().unwrap(); - let mut pull = state.pull.as_mut().unwrap(); + let pull = state.pull.as_mut().unwrap(); pull.duration = Some(gst::ClockTime::ZERO); } Err(err) => { diff --git a/video/closedcaption/src/scc_parse/imp.rs b/video/closedcaption/src/scc_parse/imp.rs index 841fb8d6..6fda83b0 100644 --- a/video/closedcaption/src/scc_parse/imp.rs +++ b/video/closedcaption/src/scc_parse/imp.rs @@ -625,7 +625,7 @@ impl SccParse { ref mut pull, .. } = *state; - let mut pull = pull.as_mut().unwrap(); + let pull = pull.as_mut().unwrap(); let scan_duration = framerate.is_none() && pull.duration.is_none(); let offset = pull.offset; @@ -662,12 +662,12 @@ impl SccParse { match self.scan_duration() { Ok(Some(tc)) => { let mut state = self.state.lock().unwrap(); - let mut pull = state.pull.as_mut().unwrap(); + let pull = state.pull.as_mut().unwrap(); pull.duration = Some(tc.time_since_daily_jam()); } Ok(None) => { let mut state = self.state.lock().unwrap(); - let mut pull = state.pull.as_mut().unwrap(); + let pull = state.pull.as_mut().unwrap(); pull.duration = Some(gst::ClockTime::ZERO); } Err(err) => { diff --git a/video/closedcaption/src/tttocea608/imp.rs b/video/closedcaption/src/tttocea608/imp.rs index 75d1000c..469f1d63 100644 --- a/video/closedcaption/src/tttocea608/imp.rs +++ b/video/closedcaption/src/tttocea608/imp.rs @@ -488,7 +488,7 @@ impl TtToCea608 { fn generate( &self, - mut state: &mut State, + state: &mut State, settings: &Settings, pts: gst::ClockTime, duration: gst::ClockTime,