// 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 MinAsync_Null() { // Min(IAE

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

, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); // Min(IAE, Func) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); // Min(IAE, Func, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); // Min(IAE, Func>) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); // Min(IAE, Func>, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); #if !NO_DEEP_CANCELLATION // Min(IAE, Func>, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); #endif // Min(IAE) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable)).AsTask()); // Min(IAE, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), CancellationToken.None).AsTask()); // Min(IAE, Func) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func)).AsTask()); // Min(IAE, Func, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(default(IAsyncEnumerable), x => x, CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAsync(AsyncEnumerable.Empty(), default(Func), CancellationToken.None).AsTask()); // Min(IAE, Func>) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x)).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>)).AsTask()); // Min(IAE, Func>, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(default(IAsyncEnumerable), x => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); #if !NO_DEEP_CANCELLATION // Min(IAE, Func>, CT) await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(default(IAsyncEnumerable), (x, ct) => new ValueTask(x), CancellationToken.None).AsTask()); await Assert.ThrowsAsync(() => AsyncEnumerable.MinAwaitWithCancellationAsync(AsyncEnumerable.Empty(), default(Func>), CancellationToken.None).AsTask()); #endif } [Fact] public async Task MinAsync_Int32() { 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_Nullable_Int32() { 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_Int64() { 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_Nullable_Int64() { 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_Double() { 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_Nullable_Double() { 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_Single() { 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_Nullable_Single() { 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_Decimal() { 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_Nullable_Decimal() { 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_TSource_Value() { 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_TSource_NonValue() { 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_TSource_Value_Empty() { var xs = new DateTimeOffset[0].ToAsyncEnumerable(); await AssertThrowsAsync(xs.MinAsync().AsTask()); await AssertThrowsAsync(xs.MinAsync(x => x).AsTask()); await AssertThrowsAsync(xs.MinAwaitAsync(x => new ValueTask(x)).AsTask()); #if !NO_DEEP_CANCELLATION await AssertThrowsAsync(xs.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x)).AsTask()); #endif } [Fact] public async Task MinAsync_TSource_NonValue_Empty() { var xs = new string[0].ToAsyncEnumerable(); Assert.Null(await xs.MinAsync()); Assert.Null(await xs.MinAsync(x => x)); Assert.Null(await xs.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Null(await xs.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_TSource_NullableValue_Empty() { var xs = new DateTimeOffset?[0].ToAsyncEnumerable(); Assert.Null(await xs.MinAsync()); Assert.Null(await xs.MinAsync(x => x)); Assert.Null(await xs.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Null(await xs.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } [Fact] public async Task MinAsync_TSource_NullableValue_SomeNull() { var xs = new DateTimeOffset?[] { null, null, DateTime.Now.AddDays(1), DateTime.Now.Subtract(TimeSpan.FromDays(1)), null, DateTime.Now.AddDays(2), DateTime.Now, null }; 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.MinAwaitAsync(x => new ValueTask(x))); #if !NO_DEEP_CANCELLATION Assert.Equal(xs.Min(), await ys.MinAwaitWithCancellationAsync((x, ct) => new ValueTask(x))); #endif } } }