diff --git a/internal/capture/stream.go b/internal/capture/stream.go
index dd3f13f2..ef19b0c2 100644
--- a/internal/capture/stream.go
+++ b/internal/capture/stream.go
@@ -64,6 +64,12 @@ func streamNew(codec codec.RTPCodec, pipelineStr func() string) *StreamManagerCt
 func (manager *StreamManagerCtx) shutdown() {
 	manager.logger.Info().Msgf("shutting down")
 
+	manager.emitMu.Lock()
+	for key := range manager.listeners {
+		delete(manager.listeners, key)
+	}
+	manager.emitMu.Unlock()
+
 	manager.destroyPipeline()
 	manager.emitStop <- true
 }