Add per-track timescale and frame timestamps to moq-lite

rs/hang/src/container/frame.rs

@@ -48,9 +48,15 @@ impl Frame {
 		let mut header = BytesMut::new();
 		value.encode_quic(&mut header).map_err(moq_net::Error::from)?;
 
-		let size = header.len() + self.payload.len();
+		let size = (header.len() + self.payload.len()) as u64;
 
-		let mut chunked = group.create_frame(size.into())?;
+		// Stamp the moq-net frame timestamp too so Lite05+ can delta-encode it on the
+		// wire independently of the container-level prefix.
+		let net_frame = moq_net::Frame {
+			size,
+			timestamp: Some(timestamp),
+		};
+		let mut chunked = group.create_frame(net_frame)?;
 		chunked.write(header.freeze())?;
 		chunked.write(self.payload.clone())?;
 		chunked.finish()?;

rs/kio/src/waiter.rs

@@ -42,6 +42,12 @@ impl Waiter {
 	pub fn register(&self, list: &mut WaiterList) {
 		list.register(self);
 	}
+
+	/// The underlying [`Waker`]. Useful for bridging into other async machinery
+	/// (e.g. `futures::task::AtomicWaker`) that needs a `Waker` directly.
+	pub fn waker(&self) -> &Waker {
+		&self.waker
+	}
 }
 
 /// A list of weak wakers waiting for notification.

rs/moq-audio/src/producer.rs

@@ -58,7 +58,11 @@ impl AudioProducer {
 		};
 
 		let name = name.into();
-		let track = broadcast.create_track(moq_net::Track::new(name.clone()))?;
+		// Audio hang frames carry microsecond timestamps; advertise that on the
+		// track so Lite05 subscribers know what scale to expect and the model
+		// layer accepts Frame::timestamp on append.
+		let track =
+			broadcast.create_track(moq_net::Track::new(name.clone()).with_timescale(hang::container::TIMESCALE))?;
 		let track = moq_mux::container::Producer::new(track, moq_mux::container::legacy::Wire);
 
 		let mut catalog_mut = catalog.clone();

rs/moq-mux/src/codec/aac/import.rs

@@ -20,7 +20,9 @@ impl Import {
 		mut catalog: crate::catalog::hang::Producer,
 		config: Config,
 	) -> crate::Result<Self> {
-		let track = broadcast.unique_track(".aac")?;
+		let track = broadcast.create_track(
+			moq_net::Track::new(broadcast.unique_name(".aac")).with_timescale(hang::container::TIMESCALE),
+		)?;
 
 		let mut audio_config = hang::catalog::AudioConfig::new(
 			hang::catalog::AAC {

rs/moq-mux/src/codec/av1/import.rs

@@ -94,7 +94,9 @@ impl Import {
 			self.catalog.lock().video.renditions.remove(&track.name);
 		}
 
-		let track = self.broadcast.unique_track(".av01")?;
+		let track = self.broadcast.create_track(
+			moq_net::Track::new(self.broadcast.unique_name(".av01")).with_timescale(hang::container::TIMESCALE),
+		)?;
 		tracing::debug!(name = ?track.name, ?config, "starting track");
 		self.catalog
 			.lock()
@@ -129,7 +131,9 @@ impl Import {
 		});
 		config.container = hang::catalog::Container::Legacy;
 
-		let track = self.broadcast.unique_track(".av01")?;
+		let track = self.broadcast.create_track(
+			moq_net::Track::new(self.broadcast.unique_name(".av01")).with_timescale(hang::container::TIMESCALE),
+		)?;
 		tracing::debug!(name = ?track.name, "starting track with minimal config");
 		self.catalog
 			.lock()
@@ -206,7 +210,9 @@ impl Import {
 			self.catalog.lock().video.renditions.remove(&track.name);
 		}
 
-		let track = self.broadcast.unique_track(".av01")?;
+		let track = self.broadcast.create_track(
+			moq_net::Track::new(self.broadcast.unique_name(".av01")).with_timescale(hang::container::TIMESCALE),
+		)?;
 		self.catalog
 			.lock()
 			.video

rs/moq-mux/src/codec/h264/export.rs

@@ -275,7 +275,9 @@ mod tests {
 
 		// Producer side: publish the broadcast with one length-prefixed video track.
 		let mut broadcast = moq_net::Broadcast::new().produce();
-		let mut track = broadcast.create_track(moq_net::Track::new("video.m4s")).unwrap();
+		let mut track = broadcast
+			.create_track(moq_net::Track::new("video.m4s").with_timescale(hang::container::TIMESCALE))
+			.unwrap();
 
 		// Group 0 (keyframe-starting group): one IDR frame.
 		let mut g0 = track.create_group(moq_net::Group { sequence: 0 }).unwrap();

rs/moq-mux/src/codec/h264/import.rs

@@ -86,7 +86,9 @@ impl Import {
 				};
 			}
 			Mode::Avc3 => {
-				let track = self.broadcast.unique_track(".avc3")?;
+				let track = self.broadcast.create_track(
+					moq_net::Track::new(self.broadcast.unique_name(".avc3")).with_timescale(hang::container::TIMESCALE),
+				)?;
 				self.track = Some(crate::container::Producer::new(
 					track,
 					crate::catalog::hang::Container::Legacy,
@@ -167,7 +169,9 @@ impl Import {
 				pps: None,
 			};
 			if self.track.is_none() {
-				let track = self.broadcast.unique_track(".avc3")?;
+				let track = self.broadcast.create_track(
+					moq_net::Track::new(self.broadcast.unique_name(".avc3")).with_timescale(hang::container::TIMESCALE),
+				)?;
 				self.track = Some(crate::container::Producer::new(
 					track,
 					crate::catalog::hang::Container::Legacy,
@@ -426,7 +430,9 @@ impl Import {
 			tracing::debug!(name = ?track.name, "reinitializing H.264 track");
 			catalog.video.renditions.remove(&track.name);
 		}
-		let track = self.broadcast.unique_track(suffix)?;
+		let track = self.broadcast.create_track(
+			moq_net::Track::new(self.broadcast.unique_name(suffix)).with_timescale(hang::container::TIMESCALE),
+		)?;
 		tracing::debug!(name = ?track.name, ?config, "starting H.264 track");
 		catalog.video.renditions.insert(track.name.clone(), config.clone());
 

rs/moq-mux/src/codec/h265/import.rs

@@ -87,7 +87,9 @@ impl Import {
 			catalog.video.renditions.remove(&track.name);
 		}
 
-		let track = self.broadcast.unique_track(".hev1")?;
+		let track = self.broadcast.create_track(
+			moq_net::Track::new(self.broadcast.unique_name(".hev1")).with_timescale(hang::container::TIMESCALE),
+		)?;
 		tracing::debug!(name = ?track.name, ?config, "starting track");
 		catalog.video.renditions.insert(track.name.clone(), config.clone());
 

rs/moq-mux/src/codec/opus/import.rs

@@ -20,7 +20,9 @@ impl Import {
 		mut catalog: crate::catalog::hang::Producer,
 		config: Config,
 	) -> crate::Result<Self> {
-		let track = broadcast.unique_track(".opus")?;
+		let track = broadcast.create_track(
+			moq_net::Track::new(broadcast.unique_name(".opus")).with_timescale(hang::container::TIMESCALE),
+		)?;
 
 		let mut audio_config = hang::catalog::AudioConfig::new(
 			hang::catalog::AudioCodec::Opus,