19 references to ExceptionAggregator
System.Core (19)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (1)
79m_channelEnumerator = ExceptionAggregator.WrapQueryEnumerator(partitions[0], m_taskGroupState.CancellationState).GetEnumerator();
System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)
136return ExceptionAggregator.WrapEnumerable(opSequential, querySettings.CancellationState).GetEnumerator(); 212return ExceptionAggregator.WrapEnumerable(opSequentialWithCancelChecks, querySettings.CancellationState).ToArray();
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (2)
139result = ExceptionAggregator.WrapEnumerable(childWithCancelChecks, cancelState).ElementAtOrDefault(m_index); 145result = ExceptionAggregator.WrapEnumerable(childWithCancelChecks, cancelState).ElementAt(m_index);
System\Linq\ParallelEnumerable.cs (14)
4435ExceptionAggregator.ThrowOCEorAggregateException(ex, settings.CancellationState); 4467ExceptionAggregator.ThrowOCEorAggregateException(ex, cancelState); 5457return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState) 5499return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState) 5500.First(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState)); 5541return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, 5586return ExceptionAggregator.WrapEnumerable( 5588.FirstOrDefault(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState)); 5635return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState).Last(); 5677return ExceptionAggregator.WrapEnumerable( 5679.Last(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState)); 5719return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState).LastOrDefault(); 5760return ExceptionAggregator.WrapEnumerable( 5762.LastOrDefault(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState));