Skip to content

Commit 6e058d9

Browse files
committed
final details
1 parent 1dfc0dd commit 6e058d9

File tree

1 file changed

+1
-9
lines changed

1 file changed

+1
-9
lines changed

src/PSParallelPipeline/Worker.cs

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -72,19 +72,11 @@ private async Task Start()
7272
{ }
7373
finally
7474
{
75-
await ProcessAllAsync(tasks);
75+
await Task.WhenAll(tasks);
7676
_output.CompleteAdding();
7777
}
7878
}
7979

80-
private static async Task ProcessAllAsync(List<Task> tasks)
81-
{
82-
while (tasks.Count > 0)
83-
{
84-
await ProcessAnyAsync(tasks);
85-
}
86-
}
87-
8880
private static async Task ProcessAnyAsync(List<Task> tasks)
8981
{
9082
Task task = await Task.WhenAny(tasks);

0 commit comments

Comments
 (0)