|
@@ -10,14 +10,14 @@ namespace System.Linq
|
|
|
{
|
|
|
public static partial class AsyncEnumerable
|
|
|
{
|
|
|
- public static Task<double> AverageAsync(this IAsyncEnumerable<int> source, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double> AverageAsync(this IAsyncEnumerable<int> source, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
|
|
|
return Core(source, cancellationToken);
|
|
|
|
|
|
- static async Task<double> Core(IAsyncEnumerable<int> _source, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double> Core(IAsyncEnumerable<int> _source, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -48,7 +48,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -57,7 +57,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, int> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, int> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -88,7 +88,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<int>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<int>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -97,7 +97,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<int>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<int>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -129,7 +129,7 @@ namespace System.Linq
|
|
|
}
|
|
|
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
- public static Task<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<int>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<int>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -138,7 +138,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<int>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<int>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -170,14 +170,14 @@ namespace System.Linq
|
|
|
}
|
|
|
#endif
|
|
|
|
|
|
- public static Task<double> AverageAsync(this IAsyncEnumerable<long> source, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double> AverageAsync(this IAsyncEnumerable<long> source, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
|
|
|
return Core(source, cancellationToken);
|
|
|
|
|
|
- static async Task<double> Core(IAsyncEnumerable<long> _source, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double> Core(IAsyncEnumerable<long> _source, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -208,7 +208,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -217,7 +217,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, long> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, long> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -248,7 +248,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<long>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<long>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -257,7 +257,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<long>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<long>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -289,7 +289,7 @@ namespace System.Linq
|
|
|
}
|
|
|
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
- public static Task<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<long>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<long>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -298,7 +298,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<long>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<long>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -330,14 +330,14 @@ namespace System.Linq
|
|
|
}
|
|
|
#endif
|
|
|
|
|
|
- public static Task<float> AverageAsync(this IAsyncEnumerable<float> source, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<float> AverageAsync(this IAsyncEnumerable<float> source, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
|
|
|
return Core(source, cancellationToken);
|
|
|
|
|
|
- static async Task<float> Core(IAsyncEnumerable<float> _source, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<float> Core(IAsyncEnumerable<float> _source, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -368,7 +368,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<float> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, float> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<float> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, float> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -377,7 +377,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<float> Core(IAsyncEnumerable<TSource> _source, Func<TSource, float> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<float> Core(IAsyncEnumerable<TSource> _source, Func<TSource, float> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -408,7 +408,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<float> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<float>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<float> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<float>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -417,7 +417,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<float> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<float>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<float> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<float>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -449,7 +449,7 @@ namespace System.Linq
|
|
|
}
|
|
|
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
- public static Task<float> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<float>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<float> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<float>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -458,7 +458,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<float> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<float>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<float> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<float>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -490,14 +490,14 @@ namespace System.Linq
|
|
|
}
|
|
|
#endif
|
|
|
|
|
|
- public static Task<double> AverageAsync(this IAsyncEnumerable<double> source, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double> AverageAsync(this IAsyncEnumerable<double> source, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
|
|
|
return Core(source, cancellationToken);
|
|
|
|
|
|
- static async Task<double> Core(IAsyncEnumerable<double> _source, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double> Core(IAsyncEnumerable<double> _source, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -528,7 +528,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, double> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, double> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -537,7 +537,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, double> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, double> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -568,7 +568,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<double>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<double>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -577,7 +577,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<double>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<double>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -609,7 +609,7 @@ namespace System.Linq
|
|
|
}
|
|
|
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
- public static Task<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<double>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<double>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -618,7 +618,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<double>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<double>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -650,14 +650,14 @@ namespace System.Linq
|
|
|
}
|
|
|
#endif
|
|
|
|
|
|
- public static Task<decimal> AverageAsync(this IAsyncEnumerable<decimal> source, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<decimal> AverageAsync(this IAsyncEnumerable<decimal> source, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
|
|
|
return Core(source, cancellationToken);
|
|
|
|
|
|
- static async Task<decimal> Core(IAsyncEnumerable<decimal> _source, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<decimal> Core(IAsyncEnumerable<decimal> _source, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -688,7 +688,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<decimal> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, decimal> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<decimal> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, decimal> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -697,7 +697,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<decimal> Core(IAsyncEnumerable<TSource> _source, Func<TSource, decimal> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<decimal> Core(IAsyncEnumerable<TSource> _source, Func<TSource, decimal> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -728,7 +728,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<decimal> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<decimal>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<decimal> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<decimal>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -737,7 +737,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<decimal> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<decimal>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<decimal> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<decimal>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -769,7 +769,7 @@ namespace System.Linq
|
|
|
}
|
|
|
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
- public static Task<decimal> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<decimal>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<decimal> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<decimal>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -778,7 +778,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<decimal> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<decimal>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<decimal> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<decimal>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -810,14 +810,14 @@ namespace System.Linq
|
|
|
}
|
|
|
#endif
|
|
|
|
|
|
- public static Task<double?> AverageAsync(this IAsyncEnumerable<int?> source, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double?> AverageAsync(this IAsyncEnumerable<int?> source, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
|
|
|
return Core(source, cancellationToken);
|
|
|
|
|
|
- static async Task<double?> Core(IAsyncEnumerable<int?> _source, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double?> Core(IAsyncEnumerable<int?> _source, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -856,7 +856,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int?> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int?> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -865,7 +865,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, int?> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, int?> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -904,7 +904,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<int?>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<int?>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -913,7 +913,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<int?>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<int?>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -953,7 +953,7 @@ namespace System.Linq
|
|
|
}
|
|
|
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
- public static Task<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<int?>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<int?>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -962,7 +962,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<int?>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<int?>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1002,14 +1002,14 @@ namespace System.Linq
|
|
|
}
|
|
|
#endif
|
|
|
|
|
|
- public static Task<double?> AverageAsync(this IAsyncEnumerable<long?> source, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double?> AverageAsync(this IAsyncEnumerable<long?> source, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
|
|
|
return Core(source, cancellationToken);
|
|
|
|
|
|
- static async Task<double?> Core(IAsyncEnumerable<long?> _source, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double?> Core(IAsyncEnumerable<long?> _source, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1048,7 +1048,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long?> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, long?> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -1057,7 +1057,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, long?> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, long?> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1096,7 +1096,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<long?>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<long?>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -1105,7 +1105,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<long?>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<long?>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1145,7 +1145,7 @@ namespace System.Linq
|
|
|
}
|
|
|
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
- public static Task<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<long?>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<long?>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -1154,7 +1154,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<long?>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<long?>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1194,14 +1194,14 @@ namespace System.Linq
|
|
|
}
|
|
|
#endif
|
|
|
|
|
|
- public static Task<float?> AverageAsync(this IAsyncEnumerable<float?> source, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<float?> AverageAsync(this IAsyncEnumerable<float?> source, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
|
|
|
return Core(source, cancellationToken);
|
|
|
|
|
|
- static async Task<float?> Core(IAsyncEnumerable<float?> _source, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<float?> Core(IAsyncEnumerable<float?> _source, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1240,7 +1240,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<float?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, float?> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<float?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, float?> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -1249,7 +1249,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<float?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, float?> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<float?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, float?> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1288,7 +1288,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<float?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<float?>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<float?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<float?>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -1297,7 +1297,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<float?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<float?>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<float?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<float?>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1337,7 +1337,7 @@ namespace System.Linq
|
|
|
}
|
|
|
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
- public static Task<float?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<float?>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<float?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<float?>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -1346,7 +1346,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<float?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<float?>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<float?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<float?>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1386,14 +1386,14 @@ namespace System.Linq
|
|
|
}
|
|
|
#endif
|
|
|
|
|
|
- public static Task<double?> AverageAsync(this IAsyncEnumerable<double?> source, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double?> AverageAsync(this IAsyncEnumerable<double?> source, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
|
|
|
return Core(source, cancellationToken);
|
|
|
|
|
|
- static async Task<double?> Core(IAsyncEnumerable<double?> _source, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double?> Core(IAsyncEnumerable<double?> _source, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1432,7 +1432,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, double?> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, double?> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -1441,7 +1441,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, double?> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, double?> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1480,7 +1480,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<double?>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<double?>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -1489,7 +1489,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<double?>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<double?>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1529,7 +1529,7 @@ namespace System.Linq
|
|
|
}
|
|
|
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
- public static Task<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<double?>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<double?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<double?>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -1538,7 +1538,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<double?>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<double?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<double?>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1578,14 +1578,14 @@ namespace System.Linq
|
|
|
}
|
|
|
#endif
|
|
|
|
|
|
- public static Task<decimal?> AverageAsync(this IAsyncEnumerable<decimal?> source, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<decimal?> AverageAsync(this IAsyncEnumerable<decimal?> source, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
|
|
|
|
return Core(source, cancellationToken);
|
|
|
|
|
|
- static async Task<decimal?> Core(IAsyncEnumerable<decimal?> _source, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<decimal?> Core(IAsyncEnumerable<decimal?> _source, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1624,7 +1624,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<decimal?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, decimal?> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<decimal?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, decimal?> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -1633,7 +1633,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<decimal?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, decimal?> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<decimal?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, decimal?> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1672,7 +1672,7 @@ namespace System.Linq
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public static Task<decimal?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<decimal?>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<decimal?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<decimal?>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -1681,7 +1681,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<decimal?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<decimal?>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<decimal?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, ValueTask<decimal?>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|
|
@@ -1721,7 +1721,7 @@ namespace System.Linq
|
|
|
}
|
|
|
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
- public static Task<decimal?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<decimal?>> selector, CancellationToken cancellationToken = default)
|
|
|
+ public static ValueTask<decimal?> AverageAsync<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<decimal?>> selector, CancellationToken cancellationToken = default)
|
|
|
{
|
|
|
if (source == null)
|
|
|
throw Error.ArgumentNull(nameof(source));
|
|
@@ -1730,7 +1730,7 @@ namespace System.Linq
|
|
|
|
|
|
return Core(source, selector, cancellationToken);
|
|
|
|
|
|
- static async Task<decimal?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<decimal?>> _selector, CancellationToken _cancellationToken)
|
|
|
+ static async ValueTask<decimal?> Core(IAsyncEnumerable<TSource> _source, Func<TSource, CancellationToken, ValueTask<decimal?>> _selector, CancellationToken _cancellationToken)
|
|
|
{
|
|
|
var e = _source.GetConfiguredAsyncEnumerator(_cancellationToken, false);
|
|
|
|