ActionBlock fun

Program.cs

using System;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;
using System.Threading.Tasks.Dataflow;

namespace ActionBlockTest
{
    class Program
    {
        static async Task Main(string[] args)
        {
            var client = new HttpClient();
            client.Timeout = TimeSpan.FromMilliseconds(30 * 1000 /* change this to 1 */);

            long totalBytes = 0;

            var block = new ActionBlock<Uri>(
                async uri =>
                {
                    var bytes = await client.GetByteArrayAsync(uri);
                    Interlocked.Add(ref totalBytes, bytes.Length);
                });

            await block.SendAsync(new Uri("https://www.bing.com"));
            await block.SendAsync(new Uri("https://www.microsoft.com"));
            block.Complete();
            await block.Completion;

            Console.WriteLine(totalBytes);
        }
    }
}