diff --git a/net/webrtc/src/webrtcsink/imp.rs b/net/webrtc/src/webrtcsink/imp.rs
index 186e4fbf..4c09f328 100644
--- a/net/webrtc/src/webrtcsink/imp.rs
+++ b/net/webrtc/src/webrtcsink/imp.rs
@@ -195,6 +195,7 @@ struct State {
     streams: HashMap<String, InputStream>,
     navigation_handler: Option<NavigationEventHandler>,
     mids: HashMap<String, String>,
+    stats_collection_handle: Option<tokio::task::JoinHandle<()>>,
 }
 
 fn create_navigation_event(sink: &super::WebRTCSink, msg: &str) {
@@ -308,6 +309,7 @@ impl Default for State {
             streams: HashMap::new(),
             navigation_handler: None,
             mids: HashMap::new(),
+            stats_collection_handle: None,
         }
     }
 }
@@ -1236,6 +1238,14 @@ impl WebRTCSink {
             });
         }
 
+        if let Some(stats_collection_handle) = state.stats_collection_handle.take() {
+            stats_collection_handle.abort();
+            // Make sure any currently running stats collection task completes
+            drop(state);
+            let _ = RUNTIME.block_on(stats_collection_handle);
+            state = self.state.lock().unwrap();
+        }
+
         state.maybe_stop_signaller(element);
 
         state.codec_discovery_done = false;
@@ -1940,7 +1950,7 @@ impl WebRTCSink {
 
             let element_clone = element.downgrade();
             let webrtcbin = session.webrtcbin.downgrade();
-            RUNTIME.spawn(async move {
+            state.stats_collection_handle = Some(RUNTIME.spawn(async move {
                 let mut interval = tokio::time::interval(std::time::Duration::from_millis(100));
 
                 loop {
@@ -1956,7 +1966,7 @@ impl WebRTCSink {
                         break;
                     }
                 }
-            });
+            }));
 
             if remove {
                 state.finalize_session(element, &mut session, true);