From 06099921b22e70d811e2fb8dc40866311c05578e Mon Sep 17 00:00:00 2001 From: Florian Forster Date: Wed, 24 Jan 2018 20:50:26 +0100 Subject: [PATCH] Defer wg.Done(). --- gfitsync.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/gfitsync.go b/gfitsync.go index eb3c953..61e9107 100644 --- a/gfitsync.go +++ b/gfitsync.go @@ -292,6 +292,8 @@ func handleNotification(ctx context.Context, s *fitbit.Subscription) error { wg.Add(1) go func() { + defer wg.Done() + var distanceMeters float64 for _, d := range summary.Summary.Distances { if d.Activity != "total" { @@ -302,8 +304,8 @@ func handleNotification(ctx context.Context, s *fitbit.Subscription) error { } if err := gfitClient.SetDistance(ctx, distanceMeters, tm); err != nil { errs = append(errs, fmt.Errorf("gfitClient.SetDistance(%d) = %v", distanceMeters, err)) + return } - wg.Done() }() wg.Add(1) -- 2.11.0