Merge pull request #1 from GuillaumeVadeBe/feature/parallel-foreach

Use Parallel.ForEach to go over all table entities

Author: GuillaumeVadeBe

Extensions/AzureTableAPI/Cosmos.DataTransfer.AzureTableAPIExtension/AzureTableAPIDataSinkExtension.cs

@@ -23,14 +23,11 @@ public async Task WriteAsync(IAsyncEnumerable<IDataItem> dataItems, IConfigurati
 
             await tableClient.CreateIfNotExistsAsync();
 
-            var createTasks = new List<Task>();
-            await foreach(var item in dataItems.WithCancellation(cancellationToken))
+            await Parallel.ForEachAsync(dataItems, cancellationToken, async (item, token) =>
             {
-               var entity = item.ToTableEntity(settings.PartitionKeyFieldName, settings.RowKeyFieldName);
-               createTasks.Add(tableClient.AddEntityAsync(entity));
-            }
-
-            await Task.WhenAll(createTasks);
+                var entity = item.ToTableEntity(settings.PartitionKeyFieldName, settings.RowKeyFieldName);
+                await tableClient.AddEntityAsync(entity, token);
+            });
         }
 
         public IEnumerable<IDataExtensionSettings> GetSettings()