From e69f57b930148a18658f2a6343099dc7160af04d Mon Sep 17 00:00:00 2001 From: Ben Sarmiento Date: Mon, 29 Jan 2024 02:26:39 +0100 Subject: [PATCH] Move info chan closure --- internal/torrent/refresh.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 {