Fix stream close on coldsync

anyproto · Feb 3, 2025 · 9221b30 · 9221b30
1 parent b1141b8
commit 9221b30
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/nodesync/coldsync/coldsync.go b/nodesync/coldsync/coldsync.go
@@ -82,6 +82,7 @@ func (c *coldSync) coldSync(ctx context.Context, spaceId, peerId string) (err er
 		}
 		if err = rd.Read(ctx); err != nil {
 			_ = os.RemoveAll(rd.dir)
+			_ = stream.Close()
 			if err == io.EOF {
 				return ErrRemoteSpaceLocked
 			} else {