ericrey85

public class AsyncLazyPipeline<TSource>
{
    private Func<Task<TSource>> Expression { get; }

    public AsyncLazyPipeline(Func<Task<TSource>> expression)
    {
        Expression = expression;
    }

    public Task<TSource> Flatten() => Expression();