1 instantiation of MergeExecutor
System.Core (1)
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
62
MergeExecutor<TInputOutput> mergeExecutor = new
MergeExecutor
<TInputOutput>();
9 references to MergeExecutor
System.Core (9)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (2)
72
MergeExecutor
<TInputOutput>.MakeAsynchronousChannels(partitions.PartitionCount, options, consumerEvent, cancellationState.MergedCancellationToken);
85
MergeExecutor
<TInputOutput>.MakeSynchronousChannels(partitions.PartitionCount);
System\Linq\Parallel\Merging\MergeExecutor.cs (2)
54
internal static
MergeExecutor
<TInputOutput> Execute<TKey>(
62
MergeExecutor
<TInputOutput> mergeExecutor = new MergeExecutor<TInputOutput>();
System\Linq\Parallel\QueryOperators\PartitionedStreamMerger.cs (3)
27
private
MergeExecutor
<TOutput> m_mergeExecutor = null;
37
internal
MergeExecutor
<TOutput> MergeExecutor
64
m_mergeExecutor =
MergeExecutor
<TOutput>.Execute<TKey>(
System\Linq\Parallel\QueryOperators\QueryOperator.cs (2)
284
MergeExecutor
<TOutput> executor =
MergeExecutor
<TOutput>.Execute<TKey>(