|
@@ -12,7 +12,7 @@ namespace System.Linq
|
|
|
{
|
|
|
private static async Task<double> AverageCore(this IAsyncEnumerable<int> source, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<int> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -23,7 +23,6 @@ namespace System.Linq
|
|
|
|
|
|
long sum = e.Current;
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
@@ -43,7 +42,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double> AverageCore<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, int> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -54,7 +53,6 @@ namespace System.Linq
|
|
|
|
|
|
long sum = selector(e.Current);
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
@@ -74,7 +72,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double> AverageCore<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<int>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -85,7 +83,6 @@ namespace System.Linq
|
|
|
|
|
|
long sum = await selector(e.Current).ConfigureAwait(false);
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
@@ -106,7 +103,7 @@ namespace System.Linq
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
private static async Task<double> AverageCore<TSource>(this IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<int>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -117,7 +114,6 @@ namespace System.Linq
|
|
|
|
|
|
long sum = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
@@ -138,25 +134,22 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double?> AverageCore(IAsyncEnumerable<int?> source, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<int?> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- int? v = e.Current;
|
|
|
-
|
|
|
+ var v = e.Current;
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
long sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = e.Current;
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -179,25 +172,22 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, int?> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- int? v = selector(e.Current);
|
|
|
-
|
|
|
+ var v = selector(e.Current);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
long sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = selector(e.Current);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -220,25 +210,22 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<int?>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- int? v = await selector(e.Current).ConfigureAwait(false);
|
|
|
-
|
|
|
+ var v = await selector(e.Current).ConfigureAwait(false);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
long sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = await selector(e.Current).ConfigureAwait(false);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -262,25 +249,22 @@ namespace System.Linq
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
private static async Task<double?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<int?>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- int? v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
-
|
|
|
+ var v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
long sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -304,7 +288,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double> AverageCore(IAsyncEnumerable<long> source, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<long> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -313,9 +297,8 @@ namespace System.Linq
|
|
|
throw Error.NoElements();
|
|
|
}
|
|
|
|
|
|
- long sum = e.Current;
|
|
|
+ var sum = e.Current;
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
@@ -335,7 +318,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, long> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -344,9 +327,8 @@ namespace System.Linq
|
|
|
throw Error.NoElements();
|
|
|
}
|
|
|
|
|
|
- long sum = selector(e.Current);
|
|
|
+ var sum = selector(e.Current);
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
@@ -366,7 +348,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<long>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -375,9 +357,8 @@ namespace System.Linq
|
|
|
throw Error.NoElements();
|
|
|
}
|
|
|
|
|
|
- long sum = await selector(e.Current).ConfigureAwait(false);
|
|
|
+ var sum = await selector(e.Current).ConfigureAwait(false);
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
@@ -398,7 +379,7 @@ namespace System.Linq
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
private static async Task<double> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<long>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -407,9 +388,8 @@ namespace System.Linq
|
|
|
throw Error.NoElements();
|
|
|
}
|
|
|
|
|
|
- long sum = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
+ var sum = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
@@ -430,25 +410,22 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double?> AverageCore(IAsyncEnumerable<long?> source, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<long?> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- long? v = e.Current;
|
|
|
-
|
|
|
+ var v = e.Current;
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
- long sum = v.GetValueOrDefault();
|
|
|
+ var sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = e.Current;
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -471,25 +448,22 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, long?> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- long? v = selector(e.Current);
|
|
|
-
|
|
|
+ var v = selector(e.Current);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
- long sum = v.GetValueOrDefault();
|
|
|
+ var sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = selector(e.Current);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -512,25 +486,22 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<long?>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- long? v = await selector(e.Current).ConfigureAwait(false);
|
|
|
-
|
|
|
+ var v = await selector(e.Current).ConfigureAwait(false);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
- long sum = v.GetValueOrDefault();
|
|
|
+ var sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = await selector(e.Current).ConfigureAwait(false);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -554,25 +525,22 @@ namespace System.Linq
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
private static async Task<double?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<long?>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- long? v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
-
|
|
|
+ var v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
- long sum = v.GetValueOrDefault();
|
|
|
+ var sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -596,7 +564,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double> AverageCore(IAsyncEnumerable<double> source, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<double> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -605,9 +573,8 @@ namespace System.Linq
|
|
|
throw Error.NoElements();
|
|
|
}
|
|
|
|
|
|
- double sum = e.Current;
|
|
|
+ var sum = e.Current;
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
// There is an opportunity to short-circuit here, in that if e.Current is
|
|
@@ -627,7 +594,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, double> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -636,9 +603,8 @@ namespace System.Linq
|
|
|
throw Error.NoElements();
|
|
|
}
|
|
|
|
|
|
- double sum = selector(e.Current);
|
|
|
+ var sum = selector(e.Current);
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
// There is an opportunity to short-circuit here, in that if e.Current is
|
|
@@ -658,7 +624,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<double>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -667,9 +633,8 @@ namespace System.Linq
|
|
|
throw Error.NoElements();
|
|
|
}
|
|
|
|
|
|
- double sum = await selector(e.Current).ConfigureAwait(false);
|
|
|
+ var sum = await selector(e.Current).ConfigureAwait(false);
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
// There is an opportunity to short-circuit here, in that if e.Current is
|
|
@@ -690,7 +655,7 @@ namespace System.Linq
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
private static async Task<double> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<double>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -699,9 +664,8 @@ namespace System.Linq
|
|
|
throw Error.NoElements();
|
|
|
}
|
|
|
|
|
|
- double sum = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
+ var sum = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
// There is an opportunity to short-circuit here, in that if e.Current is
|
|
@@ -722,25 +686,22 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double?> AverageCore(IAsyncEnumerable<double?> source, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<double?> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- double? v = e.Current;
|
|
|
-
|
|
|
+ var v = e.Current;
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
- double sum = v.GetValueOrDefault();
|
|
|
+ var sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = e.Current;
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -763,25 +724,22 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, double?> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- double? v = selector(e.Current);
|
|
|
-
|
|
|
+ var v = selector(e.Current);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
- double sum = v.GetValueOrDefault();
|
|
|
+ var sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = selector(e.Current);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -804,25 +762,22 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<double?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<double?>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- double? v = await selector(e.Current).ConfigureAwait(false);
|
|
|
-
|
|
|
+ var v = await selector(e.Current).ConfigureAwait(false);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
- double sum = v.GetValueOrDefault();
|
|
|
+ var sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = await selector(e.Current).ConfigureAwait(false);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -846,25 +801,22 @@ namespace System.Linq
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
private static async Task<double?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<double?>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- double? v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
-
|
|
|
+ var v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
- double sum = v.GetValueOrDefault();
|
|
|
+ var sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -888,7 +840,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<float> AverageCore(IAsyncEnumerable<float> source, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<float> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -899,7 +851,6 @@ namespace System.Linq
|
|
|
|
|
|
double sum = e.Current;
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
sum += e.Current;
|
|
@@ -916,7 +867,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<float> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, float> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -927,7 +878,6 @@ namespace System.Linq
|
|
|
|
|
|
double sum = selector(e.Current);
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
sum += selector(e.Current);
|
|
@@ -944,7 +894,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<float> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<float>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -955,7 +905,6 @@ namespace System.Linq
|
|
|
|
|
|
double sum = await selector(e.Current).ConfigureAwait(false);
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
sum += await selector(e.Current).ConfigureAwait(false);
|
|
@@ -973,7 +922,7 @@ namespace System.Linq
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
private static async Task<float> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<float>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -984,7 +933,6 @@ namespace System.Linq
|
|
|
|
|
|
double sum = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
sum += await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
@@ -1002,25 +950,22 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<float?> AverageCore(IAsyncEnumerable<float?> source, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<float?> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- float? v = e.Current;
|
|
|
-
|
|
|
+ var v = e.Current;
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
double sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = e.Current;
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -1043,25 +988,22 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<float?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, float?> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- float? v = selector(e.Current);
|
|
|
-
|
|
|
+ var v = selector(e.Current);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
double sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = selector(e.Current);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -1084,25 +1026,22 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<float?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<float?>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- float? v = await selector(e.Current).ConfigureAwait(false);
|
|
|
-
|
|
|
+ var v = await selector(e.Current).ConfigureAwait(false);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
double sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = await selector(e.Current).ConfigureAwait(false);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -1126,25 +1065,22 @@ namespace System.Linq
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
private static async Task<float?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<float?>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- float? v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
-
|
|
|
+ var v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
double sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
checked
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -1168,7 +1104,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<decimal> AverageCore(IAsyncEnumerable<decimal> source, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<decimal> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -1177,9 +1113,8 @@ namespace System.Linq
|
|
|
throw Error.NoElements();
|
|
|
}
|
|
|
|
|
|
- decimal sum = e.Current;
|
|
|
+ var sum = e.Current;
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
sum += e.Current;
|
|
@@ -1196,7 +1131,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<decimal> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, decimal> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -1223,7 +1158,7 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<decimal> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<decimal>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -1232,9 +1167,8 @@ namespace System.Linq
|
|
|
throw Error.NoElements();
|
|
|
}
|
|
|
|
|
|
- decimal sum = await selector(e.Current).ConfigureAwait(false);
|
|
|
+ var sum = await selector(e.Current).ConfigureAwait(false);
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
sum += await selector(e.Current).ConfigureAwait(false);
|
|
@@ -1252,7 +1186,7 @@ namespace System.Linq
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
private static async Task<decimal> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<decimal>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
@@ -1261,9 +1195,8 @@ namespace System.Linq
|
|
|
throw Error.NoElements();
|
|
|
}
|
|
|
|
|
|
- decimal sum = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
+ var sum = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
sum += await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
@@ -1281,23 +1214,20 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<decimal?> AverageCore(IAsyncEnumerable<decimal?> source, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<decimal?> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- decimal? v = e.Current;
|
|
|
-
|
|
|
+ var v = e.Current;
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
- decimal sum = v.GetValueOrDefault();
|
|
|
+ var sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = e.Current;
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -1319,23 +1249,20 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<decimal?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, decimal?> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- decimal? v = selector(e.Current);
|
|
|
-
|
|
|
+ var v = selector(e.Current);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
- decimal sum = v.GetValueOrDefault();
|
|
|
+ var sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = selector(e.Current);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -1357,23 +1284,20 @@ namespace System.Linq
|
|
|
|
|
|
private static async Task<decimal?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, ValueTask<decimal?>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- decimal? v = await selector(e.Current).ConfigureAwait(false);
|
|
|
-
|
|
|
+ var v = await selector(e.Current).ConfigureAwait(false);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
- decimal sum = v.GetValueOrDefault();
|
|
|
+ var sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = await selector(e.Current).ConfigureAwait(false);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|
|
@@ -1396,23 +1320,20 @@ namespace System.Linq
|
|
|
#if !NO_DEEP_CANCELLATION
|
|
|
private static async Task<decimal?> AverageCore<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<decimal?>> selector, CancellationToken cancellationToken)
|
|
|
{
|
|
|
- IAsyncEnumerator<TSource> e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
+ var e = source.GetAsyncEnumerator(cancellationToken);
|
|
|
|
|
|
try
|
|
|
{
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
- decimal? v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
-
|
|
|
+ var v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
- decimal sum = v.GetValueOrDefault();
|
|
|
+ var sum = v.GetValueOrDefault();
|
|
|
long count = 1;
|
|
|
-
|
|
|
while (await e.MoveNextAsync().ConfigureAwait(false))
|
|
|
{
|
|
|
v = await selector(e.Current, cancellationToken).ConfigureAwait(false);
|
|
|
-
|
|
|
if (v.HasValue)
|
|
|
{
|
|
|
sum += v.GetValueOrDefault();
|