Aggregate()

TOutput System.Linq.Parallel.AssociativeAggregationOperator< TInput, TIntermediate, TOutput >.Aggregate ( )

inlinepackage

Definition at line 108 of file AssociativeAggregationOperator.cs.

    {
        TIntermediate val = default(TIntermediate);
        bool flag = false;
        using (IEnumerator<TIntermediate> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, suppressOrderPreservation: true))
        {
            while (enumerator.MoveNext())
            {
                if (flag)
                {
                    try
                    {
                        val = _finalReduce(val, enumerator.Current);
                    }
                    catch (Exception ex)
                    {
                        throw new AggregateException(ex);
                    }
                }
                else
                {
                    val = enumerator.Current;
                    flag = true;
                }
            }
            if (!flag)
            {
                if (_throwIfEmpty)
                {
                    throw new InvalidOperationException(System.SR.NoElements);
                }
                val = ((_seedFactory == null) ? _seed : _seedFactory());
            }
        }
        try
        {
            return _resultSelector(val);
        }
        catch (Exception ex2)
        {
            throw new AggregateException(ex2);
        }
    }

References System.Linq.Parallel.AssociativeAggregationOperator< TInput, TIntermediate, TOutput >._finalReduce, System.Linq.Parallel.AssociativeAggregationOperator< TInput, TIntermediate, TOutput >._resultSelector, System.Linq.Parallel.AssociativeAggregationOperator< TInput, TIntermediate, TOutput >._seed, System.Linq.Parallel.AssociativeAggregationOperator< TInput, TIntermediate, TOutput >._seedFactory, System.Linq.Parallel.AssociativeAggregationOperator< TInput, TIntermediate, TOutput >._throwIfEmpty, and System.SR.NoElements.