diff options
| -rw-r--r-- | mux/fmp4/tests/tests.rs | 15 |
1 files changed, 11 insertions, 4 deletions
diff --git a/mux/fmp4/tests/tests.rs b/mux/fmp4/tests/tests.rs index 5e10754a..bb1b794d 100644 --- a/mux/fmp4/tests/tests.rs +++ b/mux/fmp4/tests/tests.rs @@ -77,6 +77,9 @@ fn test_buffer_flags_single_stream(cmaf: bool, set_dts: bool, caps: gst::Caps) { } } + // Crank the clock: this should bring us to the end of the first fragment + h.crank_single_clock_wait().unwrap(); + let header = h.pull().unwrap(); assert_eq!( header.flags(), @@ -312,6 +315,9 @@ fn test_buffer_flags_multi_stream() { } } + // Crank the clock: this should bring us to the end of the first fragment + h1.crank_single_clock_wait().unwrap(); + let header = h1.pull().unwrap(); assert_eq!( header.flags(), @@ -509,8 +515,7 @@ fn test_live_timeout() { } } - // Advance time and crank the clock: this should bring us to the end of the first fragment - h1.set_time(5.seconds()).unwrap(); + // Crank the clock: this should bring us to the end of the first fragment h1.crank_single_clock_wait().unwrap(); let header = h1.pull().unwrap(); @@ -728,8 +733,7 @@ fn test_gap_events() { } } - // Advance time and crank the clock: this should bring us to the end of the first fragment - h1.set_time(5.seconds()).unwrap(); + // Crank the clock: this should bring us to the end of the first fragment h1.crank_single_clock_wait().unwrap(); let header = h1.pull().unwrap(); @@ -1019,6 +1023,9 @@ fn test_single_stream_long_gops() { } } + // Crank the clock: this should bring us to the end of the first fragment + h.crank_single_clock_wait().unwrap(); + let header = h.pull().unwrap(); assert_eq!( header.flags(), |