// 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; using System.Collections.Generic; using System.Linq; using System.Threading; using System.Threading.Tasks; using Xunit; namespace Tests { public class Sum : AsyncEnumerableTests { [Fact] public async Task Sum_Null() { // Sum(IAE

) await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable)).AsTask()); // Sum(IAE

, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); // Sum(IAE, Func) await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); // Sum(IAE, Func, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); // Sum(IAE, Func>) await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); // Sum(IAE, Func>, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); #if !NO_DEEP_CANCELLATION // Sum(IAE, Func>, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.SumAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); #endif } [Fact] public async Task Sum1Async() { var xs = new[] { 1, 2, 3 }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Sum(), await ys.SumAsync()); Assert.Equal(xs.Sum(), await ys.SumAsync(x => x)); Assert.Equal(xs.Sum(), await ys.SumAwaitAsync(x => new ValueTask(x))); } [Fact] public async Task Sum2Async() { var xs = new[] { 1, default(int?), 3 }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Sum(), await ys.SumAsync()); Assert.Equal(xs.Sum(), await ys.SumAsync(x => x)); Assert.Equal(xs.Sum(), await ys.SumAwaitAsync(x => new ValueTask(x))); } [Fact] public async Task Sum3Async() { var xs = new[] { 1L, 2L, 3L }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Sum(), await ys.SumAsync()); Assert.Equal(xs.Sum(), await ys.SumAsync(x => x)); Assert.Equal(xs.Sum(), await ys.SumAwaitAsync(x => new ValueTask(x))); } [Fact] public async Task Sum4Async() { var xs = new[] { 1L, default(long?), 3L }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Sum(), await ys.SumAsync()); Assert.Equal(xs.Sum(), await ys.SumAsync(x => x)); Assert.Equal(xs.Sum(), await ys.SumAwaitAsync(x => new ValueTask(x))); } [Fact] public async Task Sum5Async() { var xs = new[] { 1.0, 2.0, 3.0 }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Sum(), await ys.SumAsync()); Assert.Equal(xs.Sum(), await ys.SumAsync(x => x)); Assert.Equal(xs.Sum(), await ys.SumAwaitAsync(x => new ValueTask(x))); } [Fact] public async Task Sum6Async() { var xs = new[] { 1.0, default(double?), 3.0 }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Sum(), await ys.SumAsync()); Assert.Equal(xs.Sum(), await ys.SumAsync(x => x)); Assert.Equal(xs.Sum(), await ys.SumAwaitAsync(x => new ValueTask(x))); } [Fact] public async Task Sum7Async() { var xs = new[] { 1.0f, 2.0f, 3.0f }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Sum(), await ys.SumAsync()); Assert.Equal(xs.Sum(), await ys.SumAsync(x => x)); Assert.Equal(xs.Sum(), await ys.SumAwaitAsync(x => new ValueTask(x))); } [Fact] public async Task Sum8Async() { var xs = new[] { 1.0f, default(float?), 3.0f }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Sum(), await ys.SumAsync()); Assert.Equal(xs.Sum(), await ys.SumAsync(x => x)); Assert.Equal(xs.Sum(), await ys.SumAwaitAsync(x => new ValueTask(x))); } [Fact] public async Task Sum9Async() { var xs = new[] { 1.0m, 2.0m, 3.0m }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Sum(), await ys.SumAsync()); Assert.Equal(xs.Sum(), await ys.SumAsync(x => x)); Assert.Equal(xs.Sum(), await ys.SumAwaitAsync(x => new ValueTask(x))); } [Fact] public async Task Sum10Async() { var xs = new[] { 1.0m, default(decimal?), 3.0m }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Sum(), await ys.SumAsync()); Assert.Equal(xs.Sum(), await ys.SumAsync(x => x)); Assert.Equal(xs.Sum(), await ys.SumAwaitAsync(x => new ValueTask(x))); } } }