diff --git a/utils/livesync/src/livesync/imp.rs b/utils/livesync/src/livesync/imp.rs index 5160f2b2..cb1eced6 100644 --- a/utils/livesync/src/livesync/imp.rs +++ b/utils/livesync/src/livesync/imp.rs @@ -1078,6 +1078,7 @@ impl LiveSync { None } else { state.buffer_queued = false; + self.cond.notify_all(); Some((buffer, lateness)) } } @@ -1142,7 +1143,6 @@ impl LiveSync { segment = state.pending_segment.take(); duplicate = lateness != BufferLateness::OnTime; - self.cond.notify_all(); } None => { // Work around borrow checker