pop bus messages only if available

This commit is contained in:
jazzfool 2024-10-13 19:01:07 +11:00
parent 2bd0c56f0a
commit b0b092d9e2

View file

@ -213,7 +213,10 @@ where
} }
let mut eos_pause = false; let mut eos_pause = false;
for msg in inner.bus.iter() { while let Some(msg) = inner
.bus
.pop_filtered(&[gst::MessageType::Error, gst::MessageType::Eos])
{
match msg.view() { match msg.view() {
gst::MessageView::Error(err) => { gst::MessageView::Error(err) => {
error!("bus returned an error: {err}"); error!("bus returned an error: {err}");