From fe69f1580db488bbabf6897e49456f9a2dbce81e Mon Sep 17 00:00:00 2001 From: jebbs Date: Sat, 15 Oct 2022 16:27:57 +0800 Subject: [PATCH] fix fetchLoop break --- service/subscription.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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)