<#@ 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" #> // 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.Collections.Generic; using System.Threading; using System.Threading.Tasks; namespace System.Linq { public static partial class AsyncEnumerable { <# var ts = new[] { "int", "long", "float", "double", "decimal", "int?", "long?", "float?", "double?", "decimal?", }; foreach (var m in new[] { "Max", "Min" }) { foreach (var t in ts) { var n = t.EndsWith("?"); #> public static Task<<#=t#>> <#=m#>(this IAsyncEnumerable<<#=t#>> source) { if (source == null) throw new ArgumentNullException(nameof(source)); <# if (n) { #> return source.Aggregate(default(<#=t#>), new Func<<#=t#>, <#=t#>, <#=t#>>(Nullable<#=m#>), CancellationToken.None); <# } else { #> return source.Aggregate(new Func<<#=t#>, <#=t#>, <#=t#>>(Math.<#=m#>), CancellationToken.None); <# } #> } public static Task<<#=t#>> <#=m#>(this IAsyncEnumerable<<#=t#>> source, CancellationToken cancellationToken) { if (source == null) throw new ArgumentNullException(nameof(source)); <# if (n) { #> return source.Aggregate(default(<#=t#>), new Func<<#=t#>, <#=t#>, <#=t#>>(Nullable<#=m#>), cancellationToken); <# } else { #> return source.Aggregate(new Func<<#=t#>, <#=t#>, <#=t#>>(Math.<#=m#>), cancellationToken); <# } #> } public static Task<<#=t#>> <#=m#>(this IAsyncEnumerable source, Func> selector) { if (source == null) throw new ArgumentNullException(nameof(source)); if (selector == null) throw new ArgumentNullException(nameof(selector)); return source.Select(selector).<#=m#>(CancellationToken.None); } public static Task<<#=t#>> <#=m#>(this IAsyncEnumerable source, Func> selector, CancellationToken cancellationToken) { if (source == null) throw new ArgumentNullException(nameof(source)); if (selector == null) throw new ArgumentNullException(nameof(selector)); return source.Select(selector).<#=m#>(cancellationToken); } public static Task<<#=t#>> <#=m#>(this IAsyncEnumerable source, Func>> selector) { if (source == null) throw new ArgumentNullException(nameof(source)); if (selector == null) throw new ArgumentNullException(nameof(selector)); return source.Select(selector).<#=m#>(CancellationToken.None); } public static Task<<#=t#>> <#=m#>(this IAsyncEnumerable source, Func>> selector, CancellationToken cancellationToken) { if (source == null) throw new ArgumentNullException(nameof(source)); if (selector == null) throw new ArgumentNullException(nameof(selector)); return source.Select(selector).<#=m#>(cancellationToken); } <# } } #> private static T? NullableMax(T? x, T? y) where T : struct, IComparable { if (!x.HasValue) return y; if (!y.HasValue) return x; if (x.Value.CompareTo(y.Value) >= 0) return x; return y; } private static T? NullableMin(T? x, T? y) where T : struct, IComparable { if (!x.HasValue) return y; if (!y.HasValue) return x; if (x.Value.CompareTo(y.Value) <= 0) return x; return y; } } }