MoveNextCore() [2/2]

override bool System.Linq.Parallel.NullableDoubleAverageAggregationOperator.NullableDoubleAverageAggregationOperatorEnumerator< TKey >.MoveNextCore ( ref Pair< double, long > currentElement )

inlineprotected

Definition at line 18 of file NullableDoubleAverageAggregationOperator.cs.

        {
            double num = 0.0;
            long num2 = 0L;
            QueryOperatorEnumerator<double?, TKey> source = _source;
            double? currentElement2 = null;
            TKey currentKey = default(TKey);
            int num3 = 0;
            while (source.MoveNext(ref currentElement2, ref currentKey))
            {
                if (currentElement2.HasValue)
                {
                    if ((num3++ & 0x3F) == 0)
                    {
                        _cancellationToken.ThrowIfCancellationRequested();
                    }
                    num += currentElement2.GetValueOrDefault();
                    num2 = checked(num2 + 1);
                }
            }
            currentElement = new Pair<double, long>(num, num2);
            return num2 > 0;
        }

References System.Linq.Parallel.InlinedAggregationOperatorEnumerator< Pair< double, long > >._cancellationToken, System.Linq.Parallel.NullableDoubleAverageAggregationOperator.NullableDoubleAverageAggregationOperatorEnumerator< TKey >._source, System.L, System.Linq.source, and System.Threading.CancellationToken.ThrowIfCancellationRequested().