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)
4407ExceptionAggregator.ThrowOCEorAggregateException(ex, settings.CancellationState); 4434ExceptionAggregator.ThrowOCEorAggregateException(ex, cancelState); 5413return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState) 5455return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState) 5456.First(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState)); 5496return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, 5541return ExceptionAggregator.WrapEnumerable( 5543.FirstOrDefault(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState)); 5590return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState).Last(); 5632return ExceptionAggregator.WrapEnumerable( 5634.Last(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState)); 5674return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState).LastOrDefault(); 5715return ExceptionAggregator.WrapEnumerable( 5717.LastOrDefault(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState));