moq-mux 0.4.0

Media muxers and demuxers for MoQ
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

use hang::container::Timestamp;

/// Tracks the minimum duration between consecutive frames.
///
/// This is the value reported as `jitter` in the catalog: a player should
/// buffer at least this much before emitting frames. Despite the name "jitter",
/// what we actually record is the *minimum frame duration* observed so far.
#[derive(Default)]
pub struct MinFrameDuration {
	last_timestamp: Option<Timestamp>,
	min_duration: Option<Timestamp>,
}

impl MinFrameDuration {
	pub fn new() -> Self {
		Self::default()
	}

	/// Record a new frame timestamp.
	///
	/// Returns the new minimum-frame-duration as a `moq_lite::Time` if it
	/// changed, so the caller can persist it on the catalog rendition. Returns
	/// `None` when this is the first observation, the timestamps are
	/// non-monotonic, or the new gap is no smaller than the recorded minimum.
	pub fn observe(&mut self, ts: Timestamp) -> Option<moq_lite::Time> {
		let last = self.last_timestamp.replace(ts)?;
		let duration = ts.checked_sub(last).ok()?;

		if duration >= self.min_duration.unwrap_or(Timestamp::MAX) {
			return None;
		}

		self.min_duration = Some(duration);
		duration.convert().ok()
	}
}