| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213 | // Licensed to the .NET Foundation under one or more agreements.// The .NET Foundation licenses this file to you under the Apache 2.0 License.// See the LICENSE file in the project root for more information. using System.Threading;using System.Threading.Tasks;namespace System.Linq{    public static partial class AsyncEnumerable    {        private sealed class CombinedSelectors2<TSource, TMiddle1, TResult> : ICombinedSelectors<TSource, TResult>        {            private readonly Func<TSource, TMiddle1> _selector1;            private readonly Func<TMiddle1, TResult> _selector2;            public CombinedSelectors2(Func<TSource, TMiddle1> selector1, Func<TMiddle1, TResult> selector2)            {                _selector1 = selector1;                _selector2 = selector2;            }            public ICombinedSelectors<TSource, TNewResult> Combine<TNewResult>(Func<TResult, TNewResult> selector) =>                new CombinedSelectors3<TSource, TMiddle1, TResult, TNewResult>(                    _selector1,                    _selector2,                    selector                );            public TResult Invoke(TSource x) => _selector2(_selector1(x));        }        private sealed class CombinedSelectors3<TSource, TMiddle1, TMiddle2, TResult> : ICombinedSelectors<TSource, TResult>        {            private readonly Func<TSource, TMiddle1> _selector1;            private readonly Func<TMiddle1, TMiddle2> _selector2;            private readonly Func<TMiddle2, TResult> _selector3;            public CombinedSelectors3(Func<TSource, TMiddle1> selector1, Func<TMiddle1, TMiddle2> selector2, Func<TMiddle2, TResult> selector3)            {                _selector1 = selector1;                _selector2 = selector2;                _selector3 = selector3;            }            public ICombinedSelectors<TSource, TNewResult> Combine<TNewResult>(Func<TResult, TNewResult> selector) =>                new CombinedSelectors4<TSource, TMiddle1, TMiddle2, TResult, TNewResult>(                    _selector1,                    _selector2,                    _selector3,                    selector                );            public TResult Invoke(TSource x) => _selector3(_selector2(_selector1(x)));        }        private sealed class CombinedSelectors4<TSource, TMiddle1, TMiddle2, TMiddle3, TResult> : ICombinedSelectors<TSource, TResult>        {            private readonly Func<TSource, TMiddle1> _selector1;            private readonly Func<TMiddle1, TMiddle2> _selector2;            private readonly Func<TMiddle2, TMiddle3> _selector3;            private readonly Func<TMiddle3, TResult> _selector4;            public CombinedSelectors4(Func<TSource, TMiddle1> selector1, Func<TMiddle1, TMiddle2> selector2, Func<TMiddle2, TMiddle3> selector3, Func<TMiddle3, TResult> selector4)            {                _selector1 = selector1;                _selector2 = selector2;                _selector3 = selector3;                _selector4 = selector4;            }            public ICombinedSelectors<TSource, TNewResult> Combine<TNewResult>(Func<TResult, TNewResult> selector) =>                new CombinedSelectors2<TSource, TResult, TNewResult>(this.Invoke, selector);            public TResult Invoke(TSource x) => _selector4(_selector3(_selector2(_selector1(x))));        }        private sealed class CombinedAsyncSelectors2<TSource, TMiddle1, TResult> : ICombinedAsyncSelectors<TSource, TResult>        {            private readonly Func<TSource, ValueTask<TMiddle1>> _selector1;            private readonly Func<TMiddle1, ValueTask<TResult>> _selector2;            public CombinedAsyncSelectors2(Func<TSource, ValueTask<TMiddle1>> selector1, Func<TMiddle1, ValueTask<TResult>> selector2)            {                _selector1 = selector1;                _selector2 = selector2;            }            public ICombinedAsyncSelectors<TSource, TNewResult> Combine<TNewResult>(Func<TResult, ValueTask<TNewResult>> selector) =>                new CombinedAsyncSelectors3<TSource, TMiddle1, TResult, TNewResult>(                    _selector1,                    _selector2,                    selector                );            public async ValueTask<TResult> Invoke(TSource x) => await _selector2(await _selector1(x).ConfigureAwait(false)).ConfigureAwait(false);        }        private sealed class CombinedAsyncSelectors3<TSource, TMiddle1, TMiddle2, TResult> : ICombinedAsyncSelectors<TSource, TResult>        {            private readonly Func<TSource, ValueTask<TMiddle1>> _selector1;            private readonly Func<TMiddle1, ValueTask<TMiddle2>> _selector2;            private readonly Func<TMiddle2, ValueTask<TResult>> _selector3;            public CombinedAsyncSelectors3(Func<TSource, ValueTask<TMiddle1>> selector1, Func<TMiddle1, ValueTask<TMiddle2>> selector2, Func<TMiddle2, ValueTask<TResult>> selector3)            {                _selector1 = selector1;                _selector2 = selector2;                _selector3 = selector3;            }            public ICombinedAsyncSelectors<TSource, TNewResult> Combine<TNewResult>(Func<TResult, ValueTask<TNewResult>> selector) =>                new CombinedAsyncSelectors4<TSource, TMiddle1, TMiddle2, TResult, TNewResult>(                    _selector1,                    _selector2,                    _selector3,                    selector                );            public async ValueTask<TResult> Invoke(TSource x) => await _selector3(await _selector2(await _selector1(x).ConfigureAwait(false)).ConfigureAwait(false)).ConfigureAwait(false);        }        private sealed class CombinedAsyncSelectors4<TSource, TMiddle1, TMiddle2, TMiddle3, TResult> : ICombinedAsyncSelectors<TSource, TResult>        {            private readonly Func<TSource, ValueTask<TMiddle1>> _selector1;            private readonly Func<TMiddle1, ValueTask<TMiddle2>> _selector2;            private readonly Func<TMiddle2, ValueTask<TMiddle3>> _selector3;            private readonly Func<TMiddle3, ValueTask<TResult>> _selector4;            public CombinedAsyncSelectors4(Func<TSource, ValueTask<TMiddle1>> selector1, Func<TMiddle1, ValueTask<TMiddle2>> selector2, Func<TMiddle2, ValueTask<TMiddle3>> selector3, Func<TMiddle3, ValueTask<TResult>> selector4)            {                _selector1 = selector1;                _selector2 = selector2;                _selector3 = selector3;                _selector4 = selector4;            }            public ICombinedAsyncSelectors<TSource, TNewResult> Combine<TNewResult>(Func<TResult, ValueTask<TNewResult>> selector) =>                new CombinedAsyncSelectors2<TSource, TResult, TNewResult>(this.Invoke, selector);            public async ValueTask<TResult> Invoke(TSource x) => await _selector4(await _selector3(await _selector2(await _selector1(x).ConfigureAwait(false)).ConfigureAwait(false)).ConfigureAwait(false)).ConfigureAwait(false);        }#if !NO_DEEP_CANCELLATION        private sealed class CombinedAsyncSelectorsWithCancellation2<TSource, TMiddle1, TResult> : ICombinedAsyncSelectorsWithCancellation<TSource, TResult>        {            private readonly Func<TSource, CancellationToken, ValueTask<TMiddle1>> _selector1;            private readonly Func<TMiddle1, CancellationToken, ValueTask<TResult>> _selector2;            public CombinedAsyncSelectorsWithCancellation2(Func<TSource, CancellationToken, ValueTask<TMiddle1>> selector1, Func<TMiddle1, CancellationToken, ValueTask<TResult>> selector2)            {                _selector1 = selector1;                _selector2 = selector2;            }            public ICombinedAsyncSelectorsWithCancellation<TSource, TNewResult> Combine<TNewResult>(Func<TResult, CancellationToken, ValueTask<TNewResult>> selector) =>                new CombinedAsyncSelectorsWithCancellation3<TSource, TMiddle1, TResult, TNewResult>(                    _selector1,                    _selector2,                    selector                );            public async ValueTask<TResult> Invoke(TSource x, CancellationToken ct) => await _selector2(await _selector1(x, ct).ConfigureAwait(false), ct).ConfigureAwait(false);        }        private sealed class CombinedAsyncSelectorsWithCancellation3<TSource, TMiddle1, TMiddle2, TResult> : ICombinedAsyncSelectorsWithCancellation<TSource, TResult>        {            private readonly Func<TSource, CancellationToken, ValueTask<TMiddle1>> _selector1;            private readonly Func<TMiddle1, CancellationToken, ValueTask<TMiddle2>> _selector2;            private readonly Func<TMiddle2, CancellationToken, ValueTask<TResult>> _selector3;            public CombinedAsyncSelectorsWithCancellation3(Func<TSource, CancellationToken, ValueTask<TMiddle1>> selector1, Func<TMiddle1, CancellationToken, ValueTask<TMiddle2>> selector2, Func<TMiddle2, CancellationToken, ValueTask<TResult>> selector3)            {                _selector1 = selector1;                _selector2 = selector2;                _selector3 = selector3;            }            public ICombinedAsyncSelectorsWithCancellation<TSource, TNewResult> Combine<TNewResult>(Func<TResult, CancellationToken, ValueTask<TNewResult>> selector) =>                new CombinedAsyncSelectorsWithCancellation4<TSource, TMiddle1, TMiddle2, TResult, TNewResult>(                    _selector1,                    _selector2,                    _selector3,                    selector                );            public async ValueTask<TResult> Invoke(TSource x, CancellationToken ct) => await _selector3(await _selector2(await _selector1(x, ct).ConfigureAwait(false), ct).ConfigureAwait(false), ct).ConfigureAwait(false);        }        private sealed class CombinedAsyncSelectorsWithCancellation4<TSource, TMiddle1, TMiddle2, TMiddle3, TResult> : ICombinedAsyncSelectorsWithCancellation<TSource, TResult>        {            private readonly Func<TSource, CancellationToken, ValueTask<TMiddle1>> _selector1;            private readonly Func<TMiddle1, CancellationToken, ValueTask<TMiddle2>> _selector2;            private readonly Func<TMiddle2, CancellationToken, ValueTask<TMiddle3>> _selector3;            private readonly Func<TMiddle3, CancellationToken, ValueTask<TResult>> _selector4;            public CombinedAsyncSelectorsWithCancellation4(Func<TSource, CancellationToken, ValueTask<TMiddle1>> selector1, Func<TMiddle1, CancellationToken, ValueTask<TMiddle2>> selector2, Func<TMiddle2, CancellationToken, ValueTask<TMiddle3>> selector3, Func<TMiddle3, CancellationToken, ValueTask<TResult>> selector4)            {                _selector1 = selector1;                _selector2 = selector2;                _selector3 = selector3;                _selector4 = selector4;            }            public ICombinedAsyncSelectorsWithCancellation<TSource, TNewResult> Combine<TNewResult>(Func<TResult, CancellationToken, ValueTask<TNewResult>> selector) =>                new CombinedAsyncSelectorsWithCancellation2<TSource, TResult, TNewResult>(this.Invoke, selector);            public async ValueTask<TResult> Invoke(TSource x, CancellationToken ct) => await _selector4(await _selector3(await _selector2(await _selector1(x, ct).ConfigureAwait(false), ct).ConfigureAwait(false), ct).ConfigureAwait(false), ct).ConfigureAwait(false);        }#endif    }}
 |