Adds stop with empty producer warning

2022-08-22 11:33:38 +03:00
parent 401bf85a10
commit 31e24c6e03
1 changed files with 6 additions and 2 deletions
@@ -74,8 +74,12 @@ func (p *Producer) start() {
 func (p *Producer) stop() {
 	log.Debug().Str("url", p.url).Msg("[streams] stop producer")

-	_ = p.element.Stop()
-	p.element = nil
+	if p.element != nil {
+		_ = p.element.Stop()
+		p.element = nil
+	} else {
+		log.Warn().Str("url", p.url).Msg("[streams] stop empty producer")
+	}
 	p.tracks = nil
 	p.state = stateNone
 }