Merge pull request #5687 from chenminjian/fix/cmd/gc

fix(cmd/gc): Run func does not return error when Emit func returns error
ipfs · Oct 29, 2018 · 8008246 · 8008246
2 parents 46ee56f + 78d878e
commit 8008246
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/core/commands/repo.go b/core/commands/repo.go
@@ -83,10 +83,14 @@ order to reclaim hard disk space.
 			errs := false
 			for res := range gcOutChan {
 				if res.Error != nil {
-					re.Emit(&GcResult{Error: res.Error.Error()})
+					if err := re.Emit(&GcResult{Error: res.Error.Error()}); err != nil {
+						return err
+					}
 					errs = true
 				} else {
-					re.Emit(&GcResult{Key: res.KeyRemoved})
+					if err := re.Emit(&GcResult{Key: res.KeyRemoved}); err != nil {
+						return err
+					}
 				}
 			}
 			if errs {