Skip to content

Commit a873535

Browse files
committed
Fix frames example
1 parent 82a617e commit a873535

File tree

1 file changed

+13
-8
lines changed

1 file changed

+13
-8
lines changed

crates/store/re_video/examples/frames.rs

Lines changed: 13 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,10 @@ fn main() {
2727
let video = std::fs::read(video_path).expect("failed to read video");
2828
let video = re_video::VideoData::load_mp4(&video).expect("failed to load video");
2929

30+
let sync_decoder = Box::new(
31+
re_video::decode::av1::SyncDav1dDecoder::new().expect("Failed to start AV1 decoder"),
32+
);
33+
3034
println!(
3135
"{} {}x{}",
3236
video.gops.len(),
@@ -38,15 +42,16 @@ fn main() {
3842
progress.enable_steady_tick(Duration::from_millis(100));
3943

4044
let frames = Arc::new(Mutex::new(Vec::new()));
45+
let on_output = {
46+
let frames = frames.clone();
47+
let progress = progress.clone();
48+
move |frame| {
49+
progress.inc(1);
50+
frames.lock().push(frame);
51+
}
52+
};
4153
let mut decoder =
42-
re_video::decode::async_decoder::AsyncDecoder::new("debug_name".to_owned(), {
43-
let frames = frames.clone();
44-
let progress = progress.clone();
45-
move |frame| {
46-
progress.inc(1);
47-
frames.lock().push(frame);
48-
}
49-
});
54+
re_video::decode::AsyncDecoder::new("debug_name".to_owned(), sync_decoder, on_output);
5055

5156
let start = Instant::now();
5257
for sample in &video.samples {

0 commit comments

Comments
 (0)