DisposeCorrelation

DisposeCorrelation.cs

private class DisposeCorrelation : IDisposable
{
    private readonly AsyncLocal<Stack<Guid>> _localStack;

    public DisposeCorrelation(AsyncLocal<Stack<Guid>> localStack)
    {
        _localStack = localStack;
    }
    public void Dispose()
    {
        var stack = _localStack.Value ?? new Stack<Guid>();

        if(stack.Count > 0)
            stack.Pop();
    }
}