From 2f16f3f6b06624fe51a8863eabe181dc29fba72f Mon Sep 17 00:00:00 2001 From: utilcore <8907060@qq.com> Date: Mon, 1 Jul 2024 12:09:01 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dminio=E5=8D=87=E7=BA=A7?= =?UTF-8?q?=E5=87=BA=E7=8E=B0=E7=9A=84bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/Util.FileStorage.Minio/MinioFileStore.cs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/Util.FileStorage.Minio/MinioFileStore.cs b/src/Util.FileStorage.Minio/MinioFileStore.cs index ce4299ef0..bfdf2d220 100644 --- a/src/Util.FileStorage.Minio/MinioFileStore.cs +++ b/src/Util.FileStorage.Minio/MinioFileStore.cs @@ -553,12 +553,12 @@ protected async Task GenerateTempDownloadUrlAsync( ProcessedName fileNam foreach ( var bucket in buckets ) { await SafeDeleteBucketAsync( new ProcessedName( bucket ), cancellationToken ); var listObjectsArgs = new ListObjectsArgs().WithBucket( bucket ).WithRecursive( true ); - client.ListObjectsAsync( listObjectsArgs, cancellationToken ).Subscribe( item => { + var list = client.ListObjectsEnumAsync(listObjectsArgs, cancellationToken); + await foreach (var item in list.ConfigureAwait(false)) { var removeObjectArgs = new RemoveObjectArgs().WithBucket( bucket ).WithObject( item.Key ); client.RemoveObjectAsync( removeObjectArgs, cancellationToken ).GetAwaiter(); - }, () => { - SafeDeleteBucketAsync( new ProcessedName( bucket ), cancellationToken ).GetAwaiter(); - } ); + } + SafeDeleteBucketAsync( new ProcessedName( bucket ), cancellationToken ).GetAwaiter(); } } }