From 9e69c102b596924d589693ce537c4fecae3aa44c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Ren=C3=A9=20=27Necoro=27=20Neumann?= Date: Sun, 26 Apr 2020 17:44:20 +0200 Subject: Handle the waitGroup internally in ForeachGo --- main.go | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) (limited to 'main.go') diff --git a/main.go b/main.go index 7a0749e..08640d1 100644 --- a/main.go +++ b/main.go @@ -5,7 +5,6 @@ import ( "fmt" "net/url" "os" - "sync" "github.com/Necoro/feed2imap-go/internal/feed" "github.com/Necoro/feed2imap-go/internal/imap" @@ -18,9 +17,7 @@ var cacheFile = flag.String("c", "feed.cache", "cache file") var verbose = flag.Bool("v", false, "enable verbose output") var debug = flag.Bool("d", false, "enable debug output") -func processFeed(feed *feed.Feed, cfg *config.Config, client *imap.Client, wg *sync.WaitGroup) { - defer wg.Done() - +func processFeed(feed *feed.Feed, cfg *config.Config, client *imap.Client) { mails, err := feed.ToMails(cfg) if err != nil { log.Errorf("Processing items of feed %s: %s", feed.Name, err) @@ -99,8 +96,8 @@ func run() error { defer c.Disconnect() - state.ForeachGo(func(f *feed.Feed, wg *sync.WaitGroup) { - processFeed(f, cfg, c, wg) + state.ForeachGo(func(f *feed.Feed) { + processFeed(f, cfg, c) }) if err = state.StoreCache(*cacheFile); err != nil { -- cgit v1.2.3