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