File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
src/Util.FileStorage.Minio Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -553,12 +553,12 @@ protected async Task<string> GenerateTempDownloadUrlAsync( ProcessedName fileNam
553553 foreach ( var bucket in buckets ) {
554554 await SafeDeleteBucketAsync ( new ProcessedName ( bucket ) , cancellationToken ) ;
555555 var listObjectsArgs = new ListObjectsArgs ( ) . WithBucket ( bucket ) . WithRecursive ( true ) ;
556- client . ListObjectsAsync ( listObjectsArgs , cancellationToken ) . Subscribe ( item => {
556+ var list = client . ListObjectsEnumAsync ( listObjectsArgs , cancellationToken ) ;
557+ await foreach ( var item in list . ConfigureAwait ( false ) ) {
557558 var removeObjectArgs = new RemoveObjectArgs ( ) . WithBucket ( bucket ) . WithObject ( item . Key ) ;
558559 client . RemoveObjectAsync ( removeObjectArgs , cancellationToken ) . GetAwaiter ( ) ;
559- } , ( ) => {
560- SafeDeleteBucketAsync ( new ProcessedName ( bucket ) , cancellationToken ) . GetAwaiter ( ) ;
561- } ) ;
560+ }
561+ SafeDeleteBucketAsync ( new ProcessedName ( bucket ) , cancellationToken ) . GetAwaiter ( ) ;
562562 }
563563 }
564564 }
You can’t perform that action at this time.
0 commit comments