Merge pull request #74 from ipfs/fix/close-query-on-move

fix: close query when finished moving
ipfs · Apr 10, 2020 · 8a9ada9 · 8a9ada9
2 parents 8e4cd22 + a7dbfb2
commit 8a9ada9
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/convert.go b/convert.go
@@ -76,11 +76,13 @@ func Move(oldPath string, newPath string, out io.Writer) error {
 			break
 		}
 		if e.Error != nil {
+			res.Close()
 			return e.Error
 		}
 
 		err := moveKey(oldDS, newDS, datastore.RawKey(e.Key))
 		if err != nil {
+			res.Close()
 			return err
 		}
 
@@ -89,6 +91,7 @@ func Move(oldPath string, newPath string, out io.Writer) error {
 			fmt.Fprintf(out, "\r%d keys so far", count)
 		}
 	}
+	res.Close()
 
 	if out != nil {
 		fmt.Fprintf(out, "\nCleaning Up...\n")