InternalAggregate()

override double System.Linq.Parallel.LongAverageAggregationOperator.InternalAggregate ( ref Exception singularExceptionToThrow )

inlineprotected

Definition at line 58 of file LongAverageAggregationOperator.cs.

    {
        checked
        {
            using IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, suppressOrderPreservation: true);
            if (!enumerator.MoveNext())
            {
                singularExceptionToThrow = new InvalidOperationException(System.SR.NoElements);
                return 0.0;
            }
            Pair<long, long> current = enumerator.Current;
            while (enumerator.MoveNext())
            {
                current.First += enumerator.Current.First;
                current.Second += enumerator.Current.Second;
            }
            return (double)current.First / (double)current.Second;
        }
    }

References System.SR.NoElements.