diff --git a/video/closedcaption/src/mcc_parse/imp.rs b/video/closedcaption/src/mcc_parse/imp.rs index 173a28cd..268ce81d 100644 --- a/video/closedcaption/src/mcc_parse/imp.rs +++ b/video/closedcaption/src/mcc_parse/imp.rs @@ -564,7 +564,7 @@ impl MccParse { } self.srcpad.push(buffer).map_err(|err| { - if err != gst::FlowError::Flushing { + if err != gst::FlowError::Flushing && err != gst::FlowError::Eos { gst::error!(CAT, obj: element, "Pushing buffer returned {:?}", err); } err diff --git a/video/closedcaption/src/scc_parse/imp.rs b/video/closedcaption/src/scc_parse/imp.rs index 1e62dc87..52ad35c9 100644 --- a/video/closedcaption/src/scc_parse/imp.rs +++ b/video/closedcaption/src/scc_parse/imp.rs @@ -454,7 +454,9 @@ impl SccParse { } self.srcpad.push_list(buffers).map_err(|err| { - gst::error!(CAT, obj: element, "Pushing buffer returned {:?}", err); + if err != gst::FlowError::Flushing && err != gst::FlowError::Eos { + gst::error!(CAT, obj: element, "Pushing buffer returned {:?}", err); + } err })?;