Aggregate()

bool System.Linq.Parallel.ElementAtQueryOperator< TSource >.Aggregate ( [MaybeNullWhen(false)] out TSource result, bool withDefaultValue )

inlinepackage

Definition at line 100 of file ElementAtQueryOperator.cs.

    {
        if (LimitsParallelism && base.SpecifiedQuerySettings.WithDefaults().ExecutionMode.Value != ParallelExecutionMode.ForceParallelism)
        {
            CancellationState cancellationState = base.SpecifiedQuerySettings.CancellationState;
            if (withDefaultValue)
            {
                IEnumerable<TSource> source = base.Child.AsSequentialQuery(cancellationState.ExternalCancellationToken);
                IEnumerable<TSource> source2 = CancellableEnumerable.Wrap(source, cancellationState.ExternalCancellationToken);
                result = ExceptionAggregator.WrapEnumerable(source2, cancellationState).ElementAtOrDefault(_index);
            }
            else
            {
                IEnumerable<TSource> source3 = base.Child.AsSequentialQuery(cancellationState.ExternalCancellationToken);
                IEnumerable<TSource> source4 = CancellableEnumerable.Wrap(source3, cancellationState.ExternalCancellationToken);
                result = ExceptionAggregator.WrapEnumerable(source4, cancellationState).ElementAt(_index);
            }
            return true;
        }
        using (IEnumerator<TSource> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered))
        {
            if (enumerator.MoveNext())
            {
                TSource current = enumerator.Current;
                result = current;
                return true;
            }
        }
        result = default(TSource);
        return false;
    }

References System.Linq.Parallel.ElementAtQueryOperator< TSource >._index, System.Linq.Parallel.ElementAtQueryOperator< TSource >.LimitsParallelism, and System.Linq.source.