System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (4)
66leftStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken),
67rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken);
73leftStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken),
74rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken);
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (4)
86ExchangeUtilities.HashRepartitionOrdered(leftStream, m_leftKeySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken),
87rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken);
92ExchangeUtilities.HashRepartition(leftStream, m_leftKeySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken),
93rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken);
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (4)
68leftPartitionedStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken),
69rightPartitionedStream, outputRecipient, settings.CancellationState.MergedCancellationToken);
75leftPartitionedStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken),
76rightPartitionedStream, outputRecipient, settings.CancellationState.MergedCancellationToken);
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (4)
88ExchangeUtilities.HashRepartitionOrdered(leftStream, m_leftKeySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken),
89rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken);
94ExchangeUtilities.HashRepartition(leftStream, m_leftKeySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken),
95rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken);
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (4)
73leftStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken);
76leftHashStream, rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken);
82leftStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken);
85leftHashStream, rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken);
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (4)
65inputStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken),
66recipient, settings.CancellationState.MergedCancellationToken);
72inputStream, null, null, m_comparer, settings.CancellationState.MergedCancellationToken),
73recipient, settings.CancellationState.MergedCancellationToken);
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (4)
81inputStream, m_keySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken),
83settings.CancellationState.MergedCancellationToken
90inputStream, m_keySelector, m_keyComparer, null, settings.CancellationState.MergedCancellationToken),
92settings.CancellationState.MergedCancellationToken
System\Linq\ParallelEnumerable.cs (31)
4435ExceptionAggregator.ThrowOCEorAggregateException(ex, settings.CancellationState);
4439DisposeEnumerator<TSource>(e2, settings.CancellationState);
4444DisposeEnumerator<TSource>(e1, settings.CancellationState);
5455IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken);
5456IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5457return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState)
5497IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken);
5498IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5499return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState)
5500.First(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState));
5539IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken);
5540IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5542settings.CancellationState).FirstOrDefault();
5584IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken);
5585IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5587childWithCancelChecks, settings.CancellationState)
5588.FirstOrDefault(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState));
5633IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken);
5634IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5635return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState).Last();
5675IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken);
5676IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5678childWithCancelChecks, settings.CancellationState)
5679.Last(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState));
5717IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken);
5718IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5719return ExceptionAggregator.WrapEnumerable(childWithCancelChecks, settings.CancellationState).LastOrDefault();
5758IEnumerable<TSource> childAsSequential = queryOp.Child.AsSequentialQuery(settings.CancellationState.ExternalCancellationToken);
5759IEnumerable<TSource> childWithCancelChecks = CancellableEnumerable.Wrap(childAsSequential, settings.CancellationState.ExternalCancellationToken);
5761childWithCancelChecks, settings.CancellationState)
5762.LastOrDefault(ExceptionAggregator.WrapFunc<TSource, bool>(predicate, settings.CancellationState));