diff --git a/net/webrtc/src/webrtcsink/imp.rs b/net/webrtc/src/webrtcsink/imp.rs
index 69c6fc50..d8d5414e 100644
--- a/net/webrtc/src/webrtcsink/imp.rs
+++ b/net/webrtc/src/webrtcsink/imp.rs
@@ -218,6 +218,7 @@ struct State {
     navigation_handler: Option<NavigationEventHandler>,
     mids: HashMap<String, String>,
     signaller_signals: Option<SignallerSignals>,
+    stats_collection_handle: Option<tokio::task::JoinHandle<()>>,
 }
 
 fn create_navigation_event(sink: &super::BaseWebRTCSink, msg: &str) {
@@ -332,6 +333,7 @@ impl Default for State {
             navigation_handler: None,
             mids: HashMap::new(),
             signaller_signals: Default::default(),
+            stats_collection_handle: None,
         }
     }
 }
@@ -1392,7 +1394,14 @@ impl BaseWebRTCSink {
             state.signaller_state = SignallerState::Stopped;
         }
 
+        let stats_collection_handle = state.stats_collection_handle.take();
         drop(state);
+
+        if let Some(stats_collection_handle) = stats_collection_handle {
+            stats_collection_handle.abort();
+            let _ = RUNTIME.block_on(stats_collection_handle);
+        }
+
         for session in sessions {
             signaller.end_session(&session.id);
         }
@@ -2539,7 +2548,7 @@ impl BaseWebRTCSink {
             let element_clone = element.downgrade();
             let webrtcbin = session.webrtcbin.downgrade();
             let session_id_clone = session_id.clone();
-            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 {
@@ -2555,7 +2564,7 @@ impl BaseWebRTCSink {
                         break;
                     }
                 }
-            });
+            }));
 
             if remove {
                 state.finalize_session(&mut session);