using System;

using System.Linq;

using System.Threading.Tasks.Dataflow;

​

var blockA = new TransformBlock<int, int>(v => {

    if (v == 5)

        throw new Exception("Unhandled exception");

    Console.WriteLine($"A{v}");

​

    return v;

}, new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = /*1*/ DataflowBlockOptions.Unbounded });

​

var blockB = new TransformBlock<int, int>(v => {

    Console.WriteLine($"B{v}");

    return v;

});

​

var blockC = new TransformBlock<int, int>(v => {

    Console.WriteLine($"C{v}");

    return v;

});

var linkOptions = new DataflowLinkOptions { PropagateCompletion = true };

blockA.LinkTo(blockB, linkOptions);

blockB.LinkTo(blockC, linkOptions);

​

var data = Enumerable.Range(1, 10);

​

foreach (var seed in data) {

    await blockA.SendAsync(seed);

}

​

blockA.Complete();

try {

    await blockC.Completion;

}

catch (Exception ex) {

    Console.WriteLine($"Pipeline failed with error: {ex.Message}.");

}

​

Console.WriteLine("Finished.");