using System;

using Polly;

using Polly.Bulkhead;

using System.Threading.Tasks;

using System.Collections.Generic;

using System.Linq;

public class Program

{

    private static readonly AsyncBulkheadPolicy _throttlePolicy = Policy.BulkheadAsync(8, int.MaxValue);

    private static readonly Random random = new Random();

    public static async Task Main()

    {

        List<int> sources = Enumerable.Range(1, 10).ToList();

        IEnumerable<Task<PolicyResult<int>>> projectTasks = null;

        try

        {   

            projectTasks = sources.Select(source => _throttlePolicy.ExecuteAndCaptureAsync(async () =>

            {

                await Task.Delay(TimeSpan.FromSeconds(0.01));

                if (random.Next() % 2 == 1)

                {               

                    throw new Exception("TEST");

                }

                else

                {

                    throw new AggregateException(new Exception("AGG TEST"));

                }

​

                return source;

            })).ToList();

​

            await Task.WhenAll(projectTasks);

            foreach (var task in projectTasks.Select(t => t.Result)

                                             .Where(r => r.Outcome != OutcomeType.Successful)

                                             .SelectMany(r => 

                                             {

                                                 if (r.FinalException is AggregateException)

                                                 {

                                                     return (r.FinalException as AggregateException).InnerExceptions;

                                                 }

                                                 else

                                                 {

                                                     return r.FinalException;

                                                 }

                                             }))

            {

                Console.WriteLine(task.FinalException.Message);

            }

        }

        catch (Exception ex)

        {

            Console.WriteLine(ex);

        }

        Console.WriteLine("Hello World");

    }

}