Last< TSource >() [2/2]

static TSource System.Linq.ParallelEnumerable.Last< TSource > ( this ParallelQuery< TSource > source, Func< TSource, bool > predicate )

inlinestatic

Definition at line 2049 of file ParallelEnumerable.cs.

    {
        if (source == null)
        {
            throw new ArgumentNullException("source");
        }
        if (predicate == null)
        {
            throw new ArgumentNullException("predicate");
        }
        LastQueryOperator<TSource> lastQueryOperator = new LastQueryOperator<TSource>(source, predicate);
        QuerySettings querySettings = lastQueryOperator.SpecifiedQuerySettings.WithDefaults();
        if (lastQueryOperator.LimitsParallelism && querySettings.ExecutionMode != ParallelExecutionMode.ForceParallelism)
        {
            IEnumerable<TSource> source2 = lastQueryOperator.Child.AsSequentialQuery(querySettings.CancellationState.ExternalCancellationToken);
            IEnumerable<TSource> source3 = CancellableEnumerable.Wrap(source2, querySettings.CancellationState.ExternalCancellationToken);
            return ExceptionAggregator.WrapEnumerable(source3, querySettings.CancellationState).Last(ExceptionAggregator.WrapFunc(predicate, querySettings.CancellationState));
        }
        return GetOneWithPossibleDefault(lastQueryOperator, throwIfTwo: false, defaultIfEmpty: false);
    }

References System.Linq.predicate, and System.Linq.source.