diff --git a/service/subscription.go b/service/subscription.go index 7a37e143..42d89581 100644 --- a/service/subscription.go +++ b/service/subscription.go @@ -72,10 +72,11 @@ func (s *Subscription) fetchLoop() { if err := s.fetch(); err != nil { s.logger.Error("fetch subscription: ", err) } +L: for { select { case <-s.ctx.Done(): - break + break L case <-ticker.C: if err := s.fetch(); err != nil { s.logger.Error("fetch subscription: ", err)