Code Quality: Enhance cancellation handling in methods (#16739)

IHaidov · ivan.haidov · web-flow · commit 005ebd4cf12c · 2025-02-15T19:56:04.000-05:00
Co-authored-by: ivan.haidov &lt;ivan.haidov@sprinterra.com&gt;
diff --git a/src/Files.App/Data/Items/WidgetFileTagsContainerItem.cs b/src/Files.App/Data/Items/WidgetFileTagsContainerItem.cs
@@ -59,7 +59,7 @@ public WidgetFileTagsContainerItem(string tagUid)
 		/// <inheritdoc/>
 		public async Task InitAsync(CancellationToken cancellationToken = default)
 		{
-			await foreach (var item in FileTagsService.GetItemsForTagAsync(_tagUid))
+			await foreach (var item in FileTagsService.GetItemsForTagAsync(_tagUid, cancellationToken))
 			{
 				var icon = await ImageService.GetIconAsync(item.Storable, default);
 				Tags.Add(new(item.Storable, icon));
diff --git a/src/Files.App/Utils/Storage/Operations/FilesystemOperations.cs b/src/Files.App/Utils/Storage/Operations/FilesystemOperations.cs
@@ -166,7 +166,7 @@ await DialogDisplayHelper.ShowDialogAsync(
 				{
 					// CopyFileFromApp only works on file not directories
 					var fsSourceFolder = await source.ToStorageItemResult();
-					var fsDestinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination));
+					var fsDestinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination), cancellationToken);
 					var fsResult = (FilesystemResult)(fsSourceFolder.ErrorCode | fsDestinationFolder.ErrorCode);
 
 					if (fsResult)
@@ -219,7 +219,7 @@ await DialogDisplayHelper.ShowDialogAsync(
 				{
 					Debug.WriteLine(System.Runtime.InteropServices.Marshal.GetLastWin32Error());
 
-					FilesystemResult<BaseStorageFolder> destinationResult = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination));
+					FilesystemResult<BaseStorageFolder> destinationResult = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination), cancellationToken);
 					var sourceResult = await source.ToStorageItemResult();
 					fsResult = sourceResult.ErrorCode | destinationResult.ErrorCode;
 
@@ -373,7 +373,7 @@ await DialogDisplayHelper.ShowDialogAsync(
 						Debug.WriteLine(System.Runtime.InteropServices.Marshal.GetLastWin32Error());
 
 						var fsSourceFolder = await source.ToStorageItemResult();
-						var fsDestinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination));
+						var fsDestinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination), cancellationToken);
 						fsResult = fsSourceFolder.ErrorCode | fsDestinationFolder.ErrorCode;
 
 						if (fsResult)
@@ -432,7 +432,7 @@ await DialogDisplayHelper.ShowDialogAsync(
 				{
 					Debug.WriteLine(System.Runtime.InteropServices.Marshal.GetLastWin32Error());
 
-					FilesystemResult<BaseStorageFolder> destinationResult = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination));
+					FilesystemResult<BaseStorageFolder> destinationResult = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination), cancellationToken);
 					var sourceResult = await source.ToStorageItemResult();
 					fsResult = sourceResult.ErrorCode | destinationResult.ErrorCode;
 
@@ -512,12 +512,12 @@ public async Task<IStorageHistory> DeleteAsync(IStorageItemWithPath source, IPro
 			{
 				if (source.ItemType == FilesystemItemType.File)
 				{
-					fsResult = await _associatedInstance.ShellViewModel.GetFileFromPathAsync(source.Path)
+					fsResult = await _associatedInstance.ShellViewModel.GetFileFromPathAsync(source.Path, cancellationToken)
 						.OnSuccess((t) => t.DeleteAsync(permanently ? StorageDeleteOption.PermanentDelete : StorageDeleteOption.Default).AsTask());
 				}
 				else if (source.ItemType == FilesystemItemType.Directory)
 				{
-					fsResult = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(source.Path)
+					fsResult = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(source.Path, cancellationToken)
 						.OnSuccess((t) => t.DeleteAsync(permanently ? StorageDeleteOption.PermanentDelete : StorageDeleteOption.Default).AsTask());
 				}
 			}
@@ -539,7 +539,7 @@ public async Task<IStorageHistory> DeleteAsync(IStorageItemWithPath source, IPro
 				// Recycle bin also stores a file starting with $I for each item
 				string iFilePath = Path.Combine(Path.GetDirectoryName(source.Path), Path.GetFileName(source.Path).Replace("$R", "$I", StringComparison.Ordinal));
 
-				await _associatedInstance.ShellViewModel.GetFileFromPathAsync(iFilePath)
+				await _associatedInstance.ShellViewModel.GetFileFromPathAsync(iFilePath, cancellationToken)
 					.OnSuccess(iFile => iFile.DeleteAsync(StorageDeleteOption.PermanentDelete).AsTask());
 			}
 			fsProgress.ReportStatus(fsResult);
@@ -738,8 +738,8 @@ public async Task<IStorageHistory> RestoreFromTrashAsync(IStorageItemWithPath so
 			{
 				if (source.ItemType == FilesystemItemType.Directory)
 				{
-					FilesystemResult<BaseStorageFolder> sourceFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(source.Path);
-					FilesystemResult<BaseStorageFolder> destinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination));
+					FilesystemResult<BaseStorageFolder> sourceFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(source.Path, cancellationToken);
+					FilesystemResult<BaseStorageFolder> destinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination), cancellationToken);
 
 					fsResult = sourceFolder.ErrorCode | destinationFolder.ErrorCode;
 					fsProgress.ReportStatus(fsResult);
@@ -759,8 +759,8 @@ public async Task<IStorageHistory> RestoreFromTrashAsync(IStorageItemWithPath so
 				}
 				else
 				{
-					FilesystemResult<BaseStorageFile> sourceFile = await _associatedInstance.ShellViewModel.GetFileFromPathAsync(source.Path);
-					FilesystemResult<BaseStorageFolder> destinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination));
+					FilesystemResult<BaseStorageFile> sourceFile = await _associatedInstance.ShellViewModel.GetFileFromPathAsync(source.Path, cancellationToken);
+					FilesystemResult<BaseStorageFolder> destinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination), cancellationToken);
 
 					fsResult = sourceFile.ErrorCode | destinationFolder.ErrorCode;
 					fsProgress.ReportStatus(fsResult);
@@ -782,7 +782,7 @@ public async Task<IStorageHistory> RestoreFromTrashAsync(IStorageItemWithPath so
 				// Recycle bin also stores a file starting with $I for each item
 				string iFilePath = Path.Combine(Path.GetDirectoryName(source.Path), Path.GetFileName(source.Path).Replace("$R", "$I", StringComparison.Ordinal));
 
-				await _associatedInstance.ShellViewModel.GetFileFromPathAsync(iFilePath)
+				await _associatedInstance.ShellViewModel.GetFileFromPathAsync(iFilePath, cancellationToken)
 					.OnSuccess(iFile => iFile.DeleteAsync(StorageDeleteOption.PermanentDelete).AsTask());
 			}
 
diff --git a/src/Files.App/Utils/Storage/Search/FolderSearch.cs b/src/Files.App/Utils/Storage/Search/FolderSearch.cs
@@ -336,7 +336,7 @@ await Task.Run(() =>
 					} while (hasNextFile);
 
 					Win32PInvoke.FindClose(hFile);
-				});
+				}, token);
 			}
 		}
 
diff --git a/src/Files.App/Utils/Storage/StorageItems/NativeStorageFile.cs b/src/Files.App/Utils/Storage/StorageItems/NativeStorageFile.cs
@@ -86,8 +86,8 @@ public override IAsyncOperation<BaseStorageFile> CopyAsync(IStorageFolder destin
 					await using (var inStream = await this.OpenStreamForReadAsync())
 					await using (var outStream = await destFile.OpenStreamForWriteAsync())
 					{
-						await inStream.CopyToAsync(outStream);
-						await outStream.FlushAsync();
+						await inStream.CopyToAsync(outStream, cancellationToken);
+						await outStream.FlushAsync(cancellationToken);
 					}
 				}
 				return destFile;
@@ -251,8 +251,8 @@ public override IAsyncAction RenameAsync(string desiredName, NameCollisionOption
 					await using (var inStream = await this.OpenStreamForReadAsync())
 					await using (var outStream = await destFile.OpenStreamForWriteAsync())
 					{
-						await inStream.CopyToAsync(outStream);
-						await outStream.FlushAsync();
+						await inStream.CopyToAsync(outStream, cancellationToken);
+						await outStream.FlushAsync(cancellationToken);
 					}
 					await DeleteAsync();
 				}
diff --git a/src/Files.App/Utils/Storage/StorageItems/StreamWithContentType.cs b/src/Files.App/Utils/Storage/StorageItems/StreamWithContentType.cs
@@ -117,7 +117,7 @@ public IAsyncOperation<bool> FlushAsync()
 
 			return AsyncInfo.Run<bool>(async (cancellationToken) =>
 			{
-				await stream.FlushAsync();
+				await stream.FlushAsync(cancellationToken);
 				return true;
 			});
 		}
diff --git a/src/Files.App/Utils/Storage/StorageItems/SystemStorageFile.cs b/src/Files.App/Utils/Storage/StorageItems/SystemStorageFile.cs
@@ -78,8 +78,8 @@ public override IAsyncOperation<BaseStorageFile> CopyAsync(IStorageFolder destin
 						await using (var inStream = await this.OpenStreamForReadAsync())
 						await using (var outStream = await destFile.OpenStreamForWriteAsync())
 						{
-							await inStream.CopyToAsync(outStream);
-							await outStream.FlushAsync();
+							await inStream.CopyToAsync(outStream, cancellationToken);
+							await outStream.FlushAsync(cancellationToken);
 						}
 						return destFile;
 					}
@@ -96,8 +96,8 @@ public override IAsyncOperation<BaseStorageFile> CopyAsync(IStorageFolder destin
 							await using (var inStream = await this.OpenStreamForReadAsync())
 							await using (var outStream = new FileStream(hFile, FileAccess.Write))
 							{
-								await inStream.CopyToAsync(outStream);
-								await outStream.FlushAsync();
+								await inStream.CopyToAsync(outStream, cancellationToken);
+								await outStream.FlushAsync(cancellationToken);
 							}
 							return new NativeStorageFile(destination, desiredNewName, DateTime.Now);
 						}
@@ -143,8 +143,8 @@ public override IAsyncAction CopyAndReplaceAsync(IStorageFile fileToReplace)
 				await using var inStream = await this.OpenStreamForReadAsync();
 				await using var outStream = await fileToReplace.OpenStreamForWriteAsync();
 
-				await inStream.CopyToAsync(outStream);
-				await outStream.FlushAsync();
+				await inStream.CopyToAsync(outStream, cancellationToken);
+				await outStream.FlushAsync(cancellationToken);
 			});
 		}
 		public override IAsyncAction MoveAndReplaceAsync(IStorageFile fileToReplace)
@@ -154,8 +154,8 @@ public override IAsyncAction MoveAndReplaceAsync(IStorageFile fileToReplace)
 				await using var inStream = await this.OpenStreamForReadAsync();
 				await using var outStream = await fileToReplace.OpenStreamForWriteAsync();
 
-				await inStream.CopyToAsync(outStream);
-				await outStream.FlushAsync();
+				await inStream.CopyToAsync(outStream, cancellationToken);
+				await outStream.FlushAsync(cancellationToken);
 				// Move unsupported, copy but do not delete original
 			});
 		}
diff --git a/src/Files.App/Utils/Storage/StorageItems/VirtualStorageFile.cs b/src/Files.App/Utils/Storage/StorageItems/VirtualStorageFile.cs
@@ -128,8 +128,8 @@ public override IAsyncOperation<BaseStorageFile> CopyAsync(IStorageFolder destin
 					await using (var inStream = await this.OpenStreamForReadAsync())
 					await using (var outStream = await destFile.OpenStreamForWriteAsync())
 					{
-						await inStream.CopyToAsync(outStream);
-						await outStream.FlushAsync();
+						await inStream.CopyToAsync(outStream, cancellationToken);
+						await outStream.FlushAsync(cancellationToken);
 					}
 					return destFile;
 				}

Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,7 @@ public WidgetFileTagsContainerItem(string tagUid)`
`59`	`59`	`/// <inheritdoc/>`
`60`	`60`	`public async Task InitAsync(CancellationToken cancellationToken = default)`
`61`	`61`	`{`
`62`		`- await foreach (var item in FileTagsService.GetItemsForTagAsync(_tagUid))`
	`62`	`+ await foreach (var item in FileTagsService.GetItemsForTagAsync(_tagUid, cancellationToken))`
`63`	`63`	`{`
`64`	`64`	`var icon = await ImageService.GetIconAsync(item.Storable, default);`
`65`	`65`	`Tags.Add(new(item.Storable, icon));`
Original file line number	Diff line number	Diff line change
`@@ -166,7 +166,7 @@ await DialogDisplayHelper.ShowDialogAsync(`
`166`	`166`	`{`
`167`	`167`	`// CopyFileFromApp only works on file not directories`
`168`	`168`	`var fsSourceFolder = await source.ToStorageItemResult();`
`169`		`- var fsDestinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination));`
	`169`	`+ var fsDestinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination), cancellationToken);`
`170`	`170`	`var fsResult = (FilesystemResult)(fsSourceFolder.ErrorCode \| fsDestinationFolder.ErrorCode);`
`171`	`171`
`172`	`172`	`if (fsResult)`
`@@ -219,7 +219,7 @@ await DialogDisplayHelper.ShowDialogAsync(`
`219`	`219`	`{`
`220`	`220`	`Debug.WriteLine(System.Runtime.InteropServices.Marshal.GetLastWin32Error());`
`221`	`221`
`222`		`- FilesystemResult<BaseStorageFolder> destinationResult = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination));`
	`222`	`+ FilesystemResult<BaseStorageFolder> destinationResult = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination), cancellationToken);`
`223`	`223`	`var sourceResult = await source.ToStorageItemResult();`
`224`	`224`	`fsResult = sourceResult.ErrorCode \| destinationResult.ErrorCode;`
`225`	`225`
`@@ -373,7 +373,7 @@ await DialogDisplayHelper.ShowDialogAsync(`
`373`	`373`	`Debug.WriteLine(System.Runtime.InteropServices.Marshal.GetLastWin32Error());`
`374`	`374`
`375`	`375`	`var fsSourceFolder = await source.ToStorageItemResult();`
`376`		`- var fsDestinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination));`
	`376`	`+ var fsDestinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination), cancellationToken);`
`377`	`377`	`fsResult = fsSourceFolder.ErrorCode \| fsDestinationFolder.ErrorCode;`
`378`	`378`
`379`	`379`	`if (fsResult)`
`@@ -432,7 +432,7 @@ await DialogDisplayHelper.ShowDialogAsync(`
`432`	`432`	`{`
`433`	`433`	`Debug.WriteLine(System.Runtime.InteropServices.Marshal.GetLastWin32Error());`
`434`	`434`
`435`		`- FilesystemResult<BaseStorageFolder> destinationResult = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination));`
	`435`	`+ FilesystemResult<BaseStorageFolder> destinationResult = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination), cancellationToken);`
`436`	`436`	`var sourceResult = await source.ToStorageItemResult();`
`437`	`437`	`fsResult = sourceResult.ErrorCode \| destinationResult.ErrorCode;`
`438`	`438`
`@@ -512,12 +512,12 @@ public async Task<IStorageHistory> DeleteAsync(IStorageItemWithPath source, IPro`
`512`	`512`	`{`
`513`	`513`	`if (source.ItemType == FilesystemItemType.File)`
`514`	`514`	`{`
`515`		`- fsResult = await _associatedInstance.ShellViewModel.GetFileFromPathAsync(source.Path)`
	`515`	`+ fsResult = await _associatedInstance.ShellViewModel.GetFileFromPathAsync(source.Path, cancellationToken)`
`516`	`516`	`.OnSuccess((t) => t.DeleteAsync(permanently ? StorageDeleteOption.PermanentDelete : StorageDeleteOption.Default).AsTask());`
`517`	`517`	`}`
`518`	`518`	`else if (source.ItemType == FilesystemItemType.Directory)`
`519`	`519`	`{`
`520`		`- fsResult = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(source.Path)`
	`520`	`+ fsResult = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(source.Path, cancellationToken)`
`521`	`521`	`.OnSuccess((t) => t.DeleteAsync(permanently ? StorageDeleteOption.PermanentDelete : StorageDeleteOption.Default).AsTask());`
`522`	`522`	`}`
`523`	`523`	`}`
`@@ -539,7 +539,7 @@ public async Task<IStorageHistory> DeleteAsync(IStorageItemWithPath source, IPro`
`539`	`539`	`// Recycle bin also stores a file starting with $I for each item`
`540`	`540`	`string iFilePath = Path.Combine(Path.GetDirectoryName(source.Path), Path.GetFileName(source.Path).Replace("$R", "$I", StringComparison.Ordinal));`
`541`	`541`
`542`		`- await _associatedInstance.ShellViewModel.GetFileFromPathAsync(iFilePath)`
	`542`	`+ await _associatedInstance.ShellViewModel.GetFileFromPathAsync(iFilePath, cancellationToken)`
`543`	`543`	`.OnSuccess(iFile => iFile.DeleteAsync(StorageDeleteOption.PermanentDelete).AsTask());`
`544`	`544`	`}`
`545`	`545`	`fsProgress.ReportStatus(fsResult);`
`@@ -738,8 +738,8 @@ public async Task<IStorageHistory> RestoreFromTrashAsync(IStorageItemWithPath so`
`738`	`738`	`{`
`739`	`739`	`if (source.ItemType == FilesystemItemType.Directory)`
`740`	`740`	`{`
`741`		`- FilesystemResult<BaseStorageFolder> sourceFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(source.Path);`
`742`		`- FilesystemResult<BaseStorageFolder> destinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination));`
	`741`	`+ FilesystemResult<BaseStorageFolder> sourceFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(source.Path, cancellationToken);`
	`742`	`+ FilesystemResult<BaseStorageFolder> destinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination), cancellationToken);`
`743`	`743`
`744`	`744`	`fsResult = sourceFolder.ErrorCode \| destinationFolder.ErrorCode;`
`745`	`745`	`fsProgress.ReportStatus(fsResult);`
`@@ -759,8 +759,8 @@ public async Task<IStorageHistory> RestoreFromTrashAsync(IStorageItemWithPath so`
`759`	`759`	`}`
`760`	`760`	`else`
`761`	`761`	`{`
`762`		`- FilesystemResult<BaseStorageFile> sourceFile = await _associatedInstance.ShellViewModel.GetFileFromPathAsync(source.Path);`
`763`		`- FilesystemResult<BaseStorageFolder> destinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination));`
	`762`	`+ FilesystemResult<BaseStorageFile> sourceFile = await _associatedInstance.ShellViewModel.GetFileFromPathAsync(source.Path, cancellationToken);`
	`763`	`+ FilesystemResult<BaseStorageFolder> destinationFolder = await _associatedInstance.ShellViewModel.GetFolderFromPathAsync(PathNormalization.GetParentDir(destination), cancellationToken);`
`764`	`764`
`765`	`765`	`fsResult = sourceFile.ErrorCode \| destinationFolder.ErrorCode;`
`766`	`766`	`fsProgress.ReportStatus(fsResult);`
`@@ -782,7 +782,7 @@ public async Task<IStorageHistory> RestoreFromTrashAsync(IStorageItemWithPath so`
`782`	`782`	`// Recycle bin also stores a file starting with $I for each item`
`783`	`783`	`string iFilePath = Path.Combine(Path.GetDirectoryName(source.Path), Path.GetFileName(source.Path).Replace("$R", "$I", StringComparison.Ordinal));`
`784`	`784`
`785`		`- await _associatedInstance.ShellViewModel.GetFileFromPathAsync(iFilePath)`
	`785`	`+ await _associatedInstance.ShellViewModel.GetFileFromPathAsync(iFilePath, cancellationToken)`
`786`	`786`	`.OnSuccess(iFile => iFile.DeleteAsync(StorageDeleteOption.PermanentDelete).AsTask());`
`787`	`787`	`}`
`788`	`788`
Original file line number	Diff line number	Diff line change
`@@ -336,7 +336,7 @@ await Task.Run(() =>`
`336`	`336`	`} while (hasNextFile);`
`337`	`337`
`338`	`338`	`Win32PInvoke.FindClose(hFile);`
`339`		`- });`
	`339`	`+ }, token);`
`340`	`340`	`}`
`341`	`341`	`}`
`342`	`342`
Original file line number	Diff line number	Diff line change
`@@ -86,8 +86,8 @@ public override IAsyncOperation<BaseStorageFile> CopyAsync(IStorageFolder destin`
`86`	`86`	`await using (var inStream = await this.OpenStreamForReadAsync())`
`87`	`87`	`await using (var outStream = await destFile.OpenStreamForWriteAsync())`
`88`	`88`	`{`
`89`		`- await inStream.CopyToAsync(outStream);`
`90`		`- await outStream.FlushAsync();`
	`89`	`+ await inStream.CopyToAsync(outStream, cancellationToken);`
	`90`	`+ await outStream.FlushAsync(cancellationToken);`
`91`	`91`	`}`
`92`	`92`	`}`
`93`	`93`	`return destFile;`
`@@ -251,8 +251,8 @@ public override IAsyncAction RenameAsync(string desiredName, NameCollisionOption`
`251`	`251`	`await using (var inStream = await this.OpenStreamForReadAsync())`
`252`	`252`	`await using (var outStream = await destFile.OpenStreamForWriteAsync())`
`253`	`253`	`{`
`254`		`- await inStream.CopyToAsync(outStream);`
`255`		`- await outStream.FlushAsync();`
	`254`	`+ await inStream.CopyToAsync(outStream, cancellationToken);`
	`255`	`+ await outStream.FlushAsync(cancellationToken);`
`256`	`256`	`}`
`257`	`257`	`await DeleteAsync();`
`258`	`258`	`}`
Original file line number	Diff line number	Diff line change
`@@ -117,7 +117,7 @@ public IAsyncOperation<bool> FlushAsync()`
`117`	`117`
`118`	`118`	`return AsyncInfo.Run<bool>(async (cancellationToken) =>`
`119`	`119`	`{`
`120`		`- await stream.FlushAsync();`
	`120`	`+ await stream.FlushAsync(cancellationToken);`
`121`	`121`	`return true;`
`122`	`122`	`});`
`123`	`123`	`}`
Original file line number	Diff line number	Diff line change
`@@ -78,8 +78,8 @@ public override IAsyncOperation<BaseStorageFile> CopyAsync(IStorageFolder destin`
`78`	`78`	`await using (var inStream = await this.OpenStreamForReadAsync())`
`79`	`79`	`await using (var outStream = await destFile.OpenStreamForWriteAsync())`
`80`	`80`	`{`
`81`		`- await inStream.CopyToAsync(outStream);`
`82`		`- await outStream.FlushAsync();`
	`81`	`+ await inStream.CopyToAsync(outStream, cancellationToken);`
	`82`	`+ await outStream.FlushAsync(cancellationToken);`
`83`	`83`	`}`
`84`	`84`	`return destFile;`
`85`	`85`	`}`
`@@ -96,8 +96,8 @@ public override IAsyncOperation<BaseStorageFile> CopyAsync(IStorageFolder destin`
`96`	`96`	`await using (var inStream = await this.OpenStreamForReadAsync())`
`97`	`97`	`await using (var outStream = new FileStream(hFile, FileAccess.Write))`
`98`	`98`	`{`
`99`		`- await inStream.CopyToAsync(outStream);`
`100`		`- await outStream.FlushAsync();`
	`99`	`+ await inStream.CopyToAsync(outStream, cancellationToken);`
	`100`	`+ await outStream.FlushAsync(cancellationToken);`
`101`	`101`	`}`
`102`	`102`	`return new NativeStorageFile(destination, desiredNewName, DateTime.Now);`
`103`	`103`	`}`
`@@ -143,8 +143,8 @@ public override IAsyncAction CopyAndReplaceAsync(IStorageFile fileToReplace)`
`143`	`143`	`await using var inStream = await this.OpenStreamForReadAsync();`
`144`	`144`	`await using var outStream = await fileToReplace.OpenStreamForWriteAsync();`
`145`	`145`
`146`		`- await inStream.CopyToAsync(outStream);`
`147`		`- await outStream.FlushAsync();`
	`146`	`+ await inStream.CopyToAsync(outStream, cancellationToken);`
	`147`	`+ await outStream.FlushAsync(cancellationToken);`
`148`	`148`	`});`
`149`	`149`	`}`
`150`	`150`	`public override IAsyncAction MoveAndReplaceAsync(IStorageFile fileToReplace)`
`@@ -154,8 +154,8 @@ public override IAsyncAction MoveAndReplaceAsync(IStorageFile fileToReplace)`
`154`	`154`	`await using var inStream = await this.OpenStreamForReadAsync();`
`155`	`155`	`await using var outStream = await fileToReplace.OpenStreamForWriteAsync();`
`156`	`156`
`157`		`- await inStream.CopyToAsync(outStream);`
`158`		`- await outStream.FlushAsync();`
	`157`	`+ await inStream.CopyToAsync(outStream, cancellationToken);`
	`158`	`+ await outStream.FlushAsync(cancellationToken);`
`159`	`159`	`// Move unsupported, copy but do not delete original`
`160`	`160`	`});`
`161`	`161`	`}`
Original file line number	Diff line number	Diff line change
`@@ -128,8 +128,8 @@ public override IAsyncOperation<BaseStorageFile> CopyAsync(IStorageFolder destin`
`128`	`128`	`await using (var inStream = await this.OpenStreamForReadAsync())`
`129`	`129`	`await using (var outStream = await destFile.OpenStreamForWriteAsync())`
`130`	`130`	`{`
`131`		`- await inStream.CopyToAsync(outStream);`
`132`		`- await outStream.FlushAsync();`
	`131`	`+ await inStream.CopyToAsync(outStream, cancellationToken);`
	`132`	`+ await outStream.FlushAsync(cancellationToken);`
`133`	`133`	`}`
`134`	`134`	`return destFile;`
`135`	`135`	`}`