From 351f070c8e9d935e0276d917e83753a3b4976bd9 Mon Sep 17 00:00:00 2001
From: Guillaume Desmottes <guillaume.desmottes@onestream.live>
Date: Thu, 12 May 2022 14:56:55 +0200
Subject: [PATCH] utils/streamproducer: reset callbacks when removing consumer

---
 gstreamer-utils/src/streamproducer.rs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/gstreamer-utils/src/streamproducer.rs b/gstreamer-utils/src/streamproducer.rs
index 6b8f34c81..d00a984d7 100644
--- a/gstreamer-utils/src/streamproducer.rs
+++ b/gstreamer-utils/src/streamproducer.rs
@@ -102,6 +102,7 @@ impl StreamProducer {
             .is_some()
         {
             gst::debug!(CAT, obj: &self.appsink, "Removed consumer {} ({:?})", name, consumer);
+            consumer.set_callbacks(gst_app::AppSrcCallbacks::builder().build());
         } else {
             gst::debug!(CAT, obj: &self.appsink, "Consumer {} ({:?}) not found", name, consumer);
         }