From 31e24c6e03e19030180dca160538e16be417119f Mon Sep 17 00:00:00 2001 From: Alexey Khit Date: Mon, 22 Aug 2022 11:33:38 +0300 Subject: [PATCH] Adds stop with empty producer warning --- cmd/streams/producer.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/cmd/streams/producer.go b/cmd/streams/producer.go index 2e6ae580..dfb4c64e 100644 --- a/cmd/streams/producer.go +++ b/cmd/streams/producer.go @@ -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 }