// 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 Min : AsyncEnumerableTests { [Fact] public async Task Min_Null() { // Min(IAE

) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable))); // Min(IAE

, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None)); // Min(IAE, Func) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func))); // Min(IAE, Func, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None)); // Min(IAE, Func>) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>))); // Min(IAE, Func>, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); #if !NO_DEEP_CANCELLATION // Min(IAE, Func>, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); #endif // Min(IAE) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable))); // Min(IAE, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None)); // Min(IAE, Func) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func))); // Min(IAE, Func, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None)); // Min(IAE, Func>) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x))); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>))); // Min(IAE, Func>, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); #if !NO_DEEP_CANCELLATION // Min(IAE, Func>, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None)); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None)); #endif } [Fact] public async Task Min1Async() { var xs = new[] { 2, 1, 3 }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Min(), await ys.MinAsync()); Assert.Equal(xs.Min(), await ys.MinAsync(x => x)); Assert.Equal(xs.Min(), await ys.MinAsync(x => new ValueTask(x))); } [Fact] public async Task Min2Async() { var xs = new[] { 2, default(int?), 3 }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Min(), await ys.MinAsync()); Assert.Equal(xs.Min(), await ys.MinAsync(x => x)); Assert.Equal(xs.Min(), await ys.MinAsync(x => new ValueTask(x))); } [Fact] public async Task Min3Async() { var xs = new[] { 2L, 1L, 3L }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Min(), await ys.MinAsync()); Assert.Equal(xs.Min(), await ys.MinAsync(x => x)); Assert.Equal(xs.Min(), await ys.MinAsync(x => new ValueTask(x))); } [Fact] public async Task Min4Async() { var xs = new[] { 2L, default(long?), 3L }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Min(), await ys.MinAsync()); Assert.Equal(xs.Min(), await ys.MinAsync(x => x)); Assert.Equal(xs.Min(), await ys.MinAsync(x => new ValueTask(x))); } [Fact] public async Task Min5Async() { var xs = new[] { 2.0, 1.0, 3.0 }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Min(), await ys.MinAsync()); Assert.Equal(xs.Min(), await ys.MinAsync(x => x)); Assert.Equal(xs.Min(), await ys.MinAsync(x => new ValueTask(x))); } [Fact] public async Task Min6Async() { var xs = new[] { 2.0, default(double?), 3.0 }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Min(), await ys.MinAsync()); Assert.Equal(xs.Min(), await ys.MinAsync(x => x)); Assert.Equal(xs.Min(), await ys.MinAsync(x => new ValueTask(x))); } [Fact] public async Task Min7Async() { var xs = new[] { 2.0f, 1.0f, 3.0f }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Min(), await ys.MinAsync()); Assert.Equal(xs.Min(), await ys.MinAsync(x => x)); Assert.Equal(xs.Min(), await ys.MinAsync(x => new ValueTask(x))); } [Fact] public async Task Min8Async() { var xs = new[] { 2.0f, default(float?), 3.0f }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Min(), await ys.MinAsync()); Assert.Equal(xs.Min(), await ys.MinAsync(x => x)); Assert.Equal(xs.Min(), await ys.MinAsync(x => new ValueTask(x))); } [Fact] public async Task Min9Async() { var xs = new[] { 2.0m, 1.0m, 3.0m }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Min(), await ys.MinAsync()); Assert.Equal(xs.Min(), await ys.MinAsync(x => x)); Assert.Equal(xs.Min(), await ys.MinAsync(x => new ValueTask(x))); } [Fact] public async Task Min10Async() { var xs = new[] { 2.0m, default(decimal?), 3.0m }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Min(), await ys.MinAsync()); Assert.Equal(xs.Min(), await ys.MinAsync(x => x)); Assert.Equal(xs.Min(), await ys.MinAsync(x => new ValueTask(x))); } [Fact] public async Task Min11Async() { var xs = new[] { DateTime.Now.AddDays(1), DateTime.Now.Subtract(TimeSpan.FromDays(1)), DateTime.Now.AddDays(2), DateTime.Now }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Min(), await ys.MinAsync()); Assert.Equal(xs.Min(), await ys.MinAsync(x => x)); Assert.Equal(xs.Min(), await ys.MinAsync(x => new ValueTask(x))); } [Fact] public async Task Min12Async() { var xs = new[] { "foo", "bar", "qux", "baz", "fred", "wilma" }; var ys = xs.ToAsyncEnumerable(); Assert.Equal(xs.Min(), await ys.MinAsync()); Assert.Equal(xs.Min(), await ys.MinAsync(x => x)); Assert.Equal(xs.Min(), await ys.MinAsync(x => new ValueTask(x))); } } }