using System;

using System.Linq;

using System.Threading.Tasks;

using System.Threading.Tasks.Dataflow;

public class Program

{

    public static async Task Main()

    {

        GroupingDataflowBlockOptions options = new()

        {

            Greedy = false,

            BoundedCapacity = 4

        };

        BatchBlock<int> foo = new(2, options);

        ActionBlock<int[]> print = new(i => Console.WriteLine($"Received [{(string.Join(", ",i))}]"));

        foo.LinkTo(print, new DataflowLinkOptions(){ PropagateCompletion = true });

        Enumerable.Range(0, 11).Select( i => foo.Post(i)).ToList();

        //Enumerable.Range(0, 11).Select(async i => await foo.SendAsync(i)).ToList();

        foo.Complete();

        await print.Completion;

    }

}