diff --git a/net/hlssink3/src/imp.rs b/net/hlssink3/src/imp.rs index 78c97480..e7fc3b8c 100644 --- a/net/hlssink3/src/imp.rs +++ b/net/hlssink3/src/imp.rs @@ -117,9 +117,7 @@ impl StartedState { } fn fragment_duration_since(&self, fragment_closed: gst::ClockTime) -> f32 { - assert!(self.fragment_opened_at.is_some()); - let fragment_opened_at = &self.fragment_opened_at.unwrap(); - let segment_duration = fragment_closed - fragment_opened_at; + let segment_duration = fragment_closed - self.fragment_opened_at.unwrap(); segment_duration.mseconds() as f32 / 1_000f32 } } diff --git a/net/raptorq/src/raptorqenc/imp.rs b/net/raptorq/src/raptorqenc/imp.rs index 56984f00..1dbc8785 100644 --- a/net/raptorq/src/raptorqenc/imp.rs +++ b/net/raptorq/src/raptorqenc/imp.rs @@ -192,13 +192,13 @@ impl RaptorqEnc { for (target_time, repair_packet) in Iterator::zip( delays .iter() - .map(|delay| base_time.opt_add(running_time).opt_add(delay)), + .map(|&delay| base_time.opt_add(running_time).opt_add(delay)), encoder .repair_packets(0, repair_symbols as u32) .chunks_exact(state.symbols_per_packet) .enumerate() .zip(&delays) - .map(|((n, packets), delay)| { + .map(|((n, packets), &delay)| { let esi = packets[0].payload_id().encoding_symbol_id(); let payload_id = RepairPayloadId {