using Microsoft.AspNetCore.HeaderPropagation;

using Microsoft.Extensions.Primitives;

using System;

using System.Linq;

using System.Threading.Tasks;

using System.Collections.Generic;

​

class Example

{

    static HeaderPropagationValues headerPropagationValues = new ();

​

    static async Task RequestSimulation(

        string requestId,

        string header1Val,

        string header2Val)

    {

        await Task.Delay(10);

        headerPropagationValues.Headers.Add("header1Name", header1Val);

        headerPropagationValues.Headers.Add("header2Name", header2Val);

        await Task.Delay(10);

        Console.WriteLine($"Request: {requestId}, {headerPropagationValues.Headers["header1Name"]}, {headerPropagationValues.Headers["header2Name"]}");

    }

​

    static async Task Main()

    {

        await Task.WhenAll(Enumerable.Range(0, 20).Select(i =>

        {

            headerPropagationValues.Headers = new Dictionary<string, StringValues>();

            return RequestSimulation(i.ToString(), $"header1_{i}", $"header2_{i}");

        }));

    }

}