fix fetchLoop break

This commit is contained in:
jebbs 2022-10-15 16:27:57 +08:00
parent 05280d01b9
commit fe69f1580d

View File

@ -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)