19 references to ExceptionAggregator
System.Linq.Parallel (19)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
76_channelEnumerator = ExceptionAggregator.WrapQueryEnumerator(partitions[0], _taskGroupState.CancellationState).GetEnumerator();
System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)
132return ExceptionAggregator.WrapEnumerable(opSequential, querySettings.CancellationState).GetEnumerator(); 205return ExceptionAggregator.WrapEnumerable(opSequentialWithCancelChecks, querySettings.CancellationState).ToArray();
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (2)
136result = ExceptionAggregator.WrapEnumerable(childWithCancelChecks, cancelState).ElementAtOrDefault(_index)!; 142result = ExceptionAggregator.WrapEnumerable(childWithCancelChecks, cancelState).ElementAt(_index);
System\Linq\ParallelEnumerable.cs (14)
4404ExceptionAggregator.ThrowOCEorAggregateException(ex, settings.CancellationState); 4431ExceptionAggregator.ThrowOCEorAggregateException(ex, cancelState); 5410return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState) 5452return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState) 5453.First(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState)); 5493return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, 5538return ExceptionAggregator.WrapEnumerable( 5540.FirstOrDefault(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState)); 5587return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState).Last(); 5629return ExceptionAggregator.WrapEnumerable( 5631.Last(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState)); 5671return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState).LastOrDefault(); 5712return ExceptionAggregator.WrapEnumerable( 5714.LastOrDefault(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState));