diff --git a/internal/torrent/refresh.go b/internal/torrent/refresh.go index c353062..91342f6 100644 --- a/internal/torrent/refresh.go +++ b/internal/torrent/refresh.go @@ -45,7 +45,6 @@ func (t *TorrentManager) refreshTorrents() []string { } wg.Wait() - close(infoChan) t.log.Infof("Fetched info for %d torrents", len(instances)) // delete expired fixers @@ -74,6 +73,7 @@ func (t *TorrentManager) refreshTorrents() []string { } t.log.Debugf("Delete once done left: %d", t.deleteOnceDone.Cardinality()) + close(infoChan) newlyFetchedKeys := mapset.NewSet[string]() noInfoCount := 0 for info := range infoChan {