diff --git a/moq-warp/src/relay/contribute.rs b/moq-warp/src/relay/contribute.rs index 2b36f86..0b61fdc 100644 --- a/moq-warp/src/relay/contribute.rs +++ b/moq-warp/src/relay/contribute.rs @@ -275,6 +275,7 @@ impl Publishers { let track = track.as_mut().context("track closed")?; // TODO don't make fatal track.push_segment(segment); + track.drain_segments(time::Instant::now()); Ok(()) }