123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676 |
- // 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.
- <#@ template debug="false" hostspecific="false" language="C#" #>
- <#@ assembly name="System.Core" #>
- <#@ import namespace="System.Linq" #>
- <#@ import namespace="System.Text" #>
- <#@ import namespace="System.Collections.Generic" #>
- <#@ output extension=".cs" #>
- <#
- int ShuffleCount = 4;
- var types = new[] { typeof(int), typeof(long), typeof(float), typeof(double), typeof(decimal) };
- Func<Type, string> toCSharp = t =>
- {
- if (t == typeof(int))
- return "int";
- else if (t == typeof(long))
- return "long";
- else if (t == typeof(float))
- return "float";
- else if (t == typeof(double))
- return "double";
- else if (t == typeof(decimal))
- return "decimal";
- throw new Exception();
- };
- Func<int, int, int, int, int[]> getRandom = (seed, N, min, max) =>
- {
- var rand = new Random(seed);
- return Enumerable.Range(0, N).Select(i => rand.Next(min, max)).ToArray();
- };
- #>
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Threading;
- using System.Threading.Tasks;
- using Xunit;
- namespace Tests
- {
- public class MinMax : AsyncEnumerableTests
- {
- <#
- foreach (var op in new[] { "Min", "Max" })
- {
- foreach (var t in types)
- {
- var cs = toCSharp(t);
- #>
- [Fact]
- public async Task <#=op#>Async_Empty_<#=t.Name#>()
- {
- await AssertThrowsAsync<InvalidOperationException>(new <#=cs#>[0].ToAsyncEnumerable().<#=op#>Async(CancellationToken.None).AsTask());
- }
- [Fact]
- public async Task <#=op#>Async_Selector_Empty_<#=t.Name#>()
- {
- await AssertThrowsAsync<InvalidOperationException>(new object[0].ToAsyncEnumerable().<#=op#>Async(_ => default(<#=cs#>), CancellationToken.None).AsTask());
- }
- [Fact]
- public async Task <#=op#>AwaitAsync_Selector_Empty_<#=t.Name#>()
- {
- await AssertThrowsAsync<InvalidOperationException>(new object[0].ToAsyncEnumerable().<#=op#>AwaitAsync(_ => default(ValueTask<<#=cs#>>), CancellationToken.None).AsTask());
- }
- #if !NO_DEEP_CANCELLATION
- [Fact]
- public async Task <#=op#>AwaitWithCancellationAsync_Selector_Empty_<#=t.Name#>()
- {
- await AssertThrowsAsync<InvalidOperationException>(new object[0].ToAsyncEnumerable().<#=op#>AwaitWithCancellationAsync((x, ct) => default(ValueTask<<#=cs#>>), CancellationToken.None).AsTask());
- }
- #endif
- [Fact]
- public async Task <#=op#>Async_Empty_Nullable_<#=t.Name#>()
- {
- Assert.Null(await new <#=cs#>?[0].ToAsyncEnumerable().<#=op#>Async(CancellationToken.None));
- }
- [Fact]
- public async Task <#=op#>Async_Selector_Empty_Nullable_<#=t.Name#>()
- {
- Assert.Null(await new object[0].ToAsyncEnumerable().<#=op#>Async(_ => default(<#=cs#>?), CancellationToken.None));
- }
- [Fact]
- public async Task <#=op#>AwaitAsync_Selector_Empty_Nullable_<#=t.Name#>()
- {
- Assert.Null(await new object[0].ToAsyncEnumerable().<#=op#>AwaitAsync(_ => default(ValueTask<<#=cs#>?>), CancellationToken.None));
- }
- #if !NO_DEEP_CANCELLATION
- [Fact]
- public async Task <#=op#>AwaitWithCancellationAsync_Selector_Empty_Nullable_<#=t.Name#>()
- {
- Assert.Null(await new object[0].ToAsyncEnumerable().<#=op#>AwaitWithCancellationAsync((x, ct) => default(ValueTask<<#=cs#>?>), CancellationToken.None));
- }
- #endif
- <#
- foreach (var n in new[] { 1, 4, 8, 16 })
- {
- var values = string.Join(", ", getRandom(n * 42, n, -100, 100));
- var valuesWithNull = string.Join(", ", getRandom(n * 42, n, -100, 100).Select((x, i) => i % 2 == 0 ? x.ToString() : "null"));
- #>
- [Fact]
- public async Task <#=op#>Async_<#=t.Name#>_<#=n#>()
- {
- var input = new <#=cs#>[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- [Fact]
- public async Task <#=op#>Async_Selector_<#=t.Name#>_<#=n#>()
- {
- var input = new <#=cs#>[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(x => x, CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- [Fact]
- public async Task <#=op#>AwaitAsync_Selector_<#=t.Name#>_<#=n#>()
- {
- var input = new <#=cs#>[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitAsync(x => new ValueTask<<#=cs#>>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- #if !NO_DEEP_CANCELLATION
- [Fact]
- public async Task <#=op#>AwaitWithCancellationAsync_Selector_<#=t.Name#>_<#=n#>()
- {
- var input = new <#=cs#>[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitWithCancellationAsync((x, ct) => new ValueTask<<#=cs#>>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- #endif
- [Fact]
- public async Task <#=op#>Async_<#=t.Name#>_Nullable_<#=n#>_NoNull()
- {
- var input = new <#=cs#>?[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- [Fact]
- public async Task <#=op#>Async_Selector_<#=t.Name#>_Nullable_<#=n#>_NoNull()
- {
- var input = new <#=cs#>?[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(x => x, CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- [Fact]
- public async Task <#=op#>AwaitAsync_Selector_<#=t.Name#>_Nullable_<#=n#>_NoNull()
- {
- var input = new <#=cs#>?[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitAsync(x => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- #if !NO_DEEP_CANCELLATION
- [Fact]
- public async Task <#=op#>AwaitWithCancellationAsync_Selector_<#=t.Name#>_Nullable_<#=n#>_NoNull()
- {
- var input = new <#=cs#>?[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitWithCancellationAsync((x, ct) => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- #endif
- [Fact]
- public async Task <#=op#>Async_<#=t.Name#>_Nullable_<#=n#>_AllNull()
- {
- var input = Enumerable.Repeat(default(<#=cs#>?), <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- [Fact]
- public async Task <#=op#>Async_Selector_<#=t.Name#>_Nullable_<#=n#>_AllNull()
- {
- var input = Enumerable.Repeat(default(<#=cs#>?), <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(x => x, CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- [Fact]
- public async Task <#=op#>AwaitAsync_Selector_<#=t.Name#>_Nullable_<#=n#>_AllNull()
- {
- var input = Enumerable.Repeat(default(<#=cs#>?), <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitAsync(x => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- #if !NO_DEEP_CANCELLATION
- [Fact]
- public async Task <#=op#>AwaitWithCancellationAsync_Selector_<#=t.Name#>_Nullable_<#=n#>_AllNull()
- {
- var input = Enumerable.Repeat(default(<#=cs#>?), <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitWithCancellationAsync((x, ct) => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- #endif
- [Fact]
- public async Task <#=op#>Async_<#=t.Name#>_Nullable_<#=n#>_SomeNull()
- {
- var input = new <#=cs#>?[] { <#=valuesWithNull#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- [Fact]
- public async Task <#=op#>Async_Selector_<#=t.Name#>_Nullable_<#=n#>_SomeNull()
- {
- var input = new <#=cs#>?[] { <#=valuesWithNull#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(x => x, CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- [Fact]
- public async Task <#=op#>AwaitAsync_Selector_<#=t.Name#>_Nullable_<#=n#>_SomeNull()
- {
- var input = new <#=cs#>?[] { <#=valuesWithNull#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitAsync(x => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- #if !NO_DEEP_CANCELLATION
- [Fact]
- public async Task <#=op#>AwaitWithCancellationAsync_Selector_<#=t.Name#>_Nullable_<#=n#>_SomeNull()
- {
- var input = new <#=cs#>?[] { <#=valuesWithNull#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitWithCancellationAsync((x, ct) => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- #endif
- <#
- }
- if (t == typeof(float) || t == typeof(double))
- {
- foreach (var n in new[] { 1, 4, 8, 16 })
- {
- var values = string.Join(", ", getRandom(n * 42, n, -100, 100).Select((x, i) => i % 2 == 0 ? toCSharp(t) + ".NaN" : x.ToString()));
- var valuesWithNull = string.Join(", ", getRandom(n * 42, n, -100, 100).Select((x, i) => i % 3 == 0 ? x.ToString() : (i % 3 == 1 ? "null" : toCSharp(t) + ".NaN")));
- #>
- [Fact]
- public async Task <#=op#>Async_<#=t.Name#>_WithNaN_<#=n#>()
- {
- var input = new <#=cs#>[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- [Fact]
- public async Task <#=op#>Async_Selector_<#=t.Name#>_WithNaN_<#=n#>()
- {
- var input = new <#=cs#>[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(x => x, CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- [Fact]
- public async Task <#=op#>AwaitAsync_Selector_<#=t.Name#>_WithNaN_<#=n#>()
- {
- var input = new <#=cs#>[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitAsync(x => new ValueTask<<#=cs#>>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- #if !NO_DEEP_CANCELLATION
- [Fact]
- public async Task <#=op#>AwaitWithCancellationAsync_Selector_<#=t.Name#>_WithNaN_<#=n#>()
- {
- var input = new <#=cs#>[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitWithCancellationAsync((x, ct) => new ValueTask<<#=cs#>>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- #endif
- [Fact]
- public async Task <#=op#>Async_<#=t.Name#>_WithNaN_<#=n#>_AllNaN()
- {
- var input = Enumerable.Repeat(<#=toCSharp(t)#>.NaN, <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- [Fact]
- public async Task <#=op#>Async_Selector_<#=t.Name#>_WithNaN_<#=n#>_AllNaN()
- {
- var input = Enumerable.Repeat(<#=toCSharp(t)#>.NaN, <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(x => x, CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- [Fact]
- public async Task <#=op#>AwaitAsync_Selector_<#=t.Name#>_WithNaN_<#=n#>_AllNaN()
- {
- var input = Enumerable.Repeat(<#=toCSharp(t)#>.NaN, <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitAsync(x => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- #if !NO_DEEP_CANCELLATION
- [Fact]
- public async Task <#=op#>AwaitWithCancellationAsync_Selector_<#=t.Name#>_WithNaN_<#=n#>_AllNaN()
- {
- var input = Enumerable.Repeat(<#=toCSharp(t)#>.NaN, <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitWithCancellationAsync((x, ct) => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- #endif
- [Fact]
- public async Task <#=op#>Async_<#=t.Name#>_WithNaN_Nullable_<#=n#>_NoNull()
- {
- var input = new <#=cs#>?[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- [Fact]
- public async Task <#=op#>Async_Selector_<#=t.Name#>_WithNaN_Nullable_<#=n#>_NoNull()
- {
- var input = new <#=cs#>?[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(x => x, CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- [Fact]
- public async Task <#=op#>AwaitAsync_Selector_<#=t.Name#>_WithNaN_Nullable_<#=n#>_NoNull()
- {
- var input = new <#=cs#>?[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitAsync(x => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- #if !NO_DEEP_CANCELLATION
- [Fact]
- public async Task <#=op#>AwaitWithCancellationAsync_Selector_<#=t.Name#>_WithNaN_Nullable_<#=n#>_NoNull()
- {
- var input = new <#=cs#>?[] { <#=values#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitWithCancellationAsync((x, ct) => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- #endif
- [Fact]
- public async Task <#=op#>Async_<#=t.Name#>_WithNaN_Nullable_<#=n#>_AllNull()
- {
- var input = Enumerable.Repeat(default(<#=cs#>?), <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- [Fact]
- public async Task <#=op#>Async_Selector_<#=t.Name#>_WithNaN_Nullable_<#=n#>_AllNull()
- {
- var input = Enumerable.Repeat(default(<#=cs#>?), <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(x => x, CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- [Fact]
- public async Task <#=op#>AwaitAsync_Selector_<#=t.Name#>_WithNaN_Nullable_<#=n#>_AllNull()
- {
- var input = Enumerable.Repeat(default(<#=cs#>?), <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitAsync(x => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- #if !NO_DEEP_CANCELLATION
- [Fact]
- public async Task <#=op#>AwaitWithCancellationAsync_Selector_<#=t.Name#>_WithNaN_Nullable_<#=n#>_AllNull()
- {
- var input = Enumerable.Repeat(default(<#=cs#>?), <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitWithCancellationAsync((x, ct) => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- #endif
- [Fact]
- public async Task <#=op#>Async_<#=t.Name#>_WithNaN_Nullable_<#=n#>_AllNaN()
- {
- var input = Enumerable.Repeat<<#=toCSharp(t)#>?>(<#=toCSharp(t)#>.NaN, <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- [Fact]
- public async Task <#=op#>Async_Selector_<#=t.Name#>_WithNaN_Nullable_<#=n#>_AllNaN()
- {
- var input = Enumerable.Repeat<<#=toCSharp(t)#>?>(<#=toCSharp(t)#>.NaN, <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(x => x, CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- [Fact]
- public async Task <#=op#>AwaitAsync_Selector_<#=t.Name#>_WithNaN_Nullable_<#=n#>_AllNaN()
- {
- var input = Enumerable.Repeat<<#=toCSharp(t)#>?>(<#=toCSharp(t)#>.NaN, <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitAsync(x => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- #if !NO_DEEP_CANCELLATION
- [Fact]
- public async Task <#=op#>AwaitWithCancellationAsync_Selector_<#=t.Name#>_WithNaN_Nullable_<#=n#>_AllNaN()
- {
- var input = Enumerable.Repeat<<#=toCSharp(t)#>?>(<#=toCSharp(t)#>.NaN, <#=n#>);
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitWithCancellationAsync((x, ct) => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- }
- #endif
- [Fact]
- public async Task <#=op#>Async_<#=t.Name#>_WithNaN_Nullable_<#=n#>_SomeNull()
- {
- var input = new <#=cs#>?[] { <#=valuesWithNull#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- [Fact]
- public async Task <#=op#>Async_Selector_<#=t.Name#>_WithNaN_Nullable_<#=n#>_SomeNull()
- {
- var input = new <#=cs#>?[] { <#=valuesWithNull#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>Async(x => x, CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- [Fact]
- public async Task <#=op#>AwaitAsync_Selector_<#=t.Name#>_WithNaN_Nullable_<#=n#>_SomeNull()
- {
- var input = new <#=cs#>?[] { <#=valuesWithNull#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitAsync(x => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- #if !NO_DEEP_CANCELLATION
- [Fact]
- public async Task <#=op#>AwaitWithCancellationAsync_Selector_<#=t.Name#>_WithNaN_Nullable_<#=n#>_SomeNull()
- {
- var input = new <#=cs#>?[] { <#=valuesWithNull#> }.AsEnumerable();
- for (var i = 0; i < <#=ShuffleCount#>; i++)
- {
- var expected = input.<#=op#>();
- var actual = await input.ToAsyncEnumerable().<#=op#>AwaitWithCancellationAsync((x, ct) => new ValueTask<<#=cs#>?>(x), CancellationToken.None);
- Assert.Equal(expected, actual);
- input = Shuffle(input);
- }
- }
- #endif
- <#
- }
- }
- }
- }
- #>
- private static IEnumerable<T> Shuffle<T>(IEnumerable<T> source)
- {
- var rand = new Random(42);
- return source.OrderBy(x => rand.Next());
- }
- }
- }
|